Re: [DISCUSS] FLIP-451: Refactor Async sink API

2024-05-21 Thread Ahmed Hamdy
Hi Hong, Thanks for pointing that out, no we are not deprecating getFatalExceptionCons(). I have updated the FLIP Best Regards Ahmed Hamdy On Mon, 20 May 2024 at 15:40, Hong Liang wrote: > Hi Ahmed, > Thanks for putting this together! Should we still be marking > getFatalException

Re: [DISCUSS] FLIP-451: Refactor Async sink API

2024-05-21 Thread Ahmed Hamdy
ching, I fixed the incomplete methods, This should clarify how the new method is going to be integrated with the rest of the writer. Regarding the sendTime variable, I have replaced it with requestTimestamp; this is an unchanged part of the code to ensure the existing completeRequest method is unchanged

Re: [DISCUSS] FLIP-451: Refactor Async sink API

2024-05-22 Thread Ahmed Hamdy
ward compatibility has > been considered for all public interfaces the FLIP changed. > Done Best Regards Ahmed Hamdy On Wed, 22 May 2024 at 04:16, Leonard Xu wrote: > Thanks for your reply, Ahmed. > > > (2) The FLIP-451 aims to introduce a timeout configuration, but I didn’t

Re: [VOTE] FLIP-451: Introduce timeout configuration to AsyncSink

2024-05-22 Thread Ahmed Hamdy
Hi all, Thanks for all your votes, I hereby close the vote and I'll announce the results in a separate email. Best Regards Ahmed Hamdy On Wed, 22 May 2024 at 11:30, weijie guo wrote: > Thanks Ahmed for introducing this FLIP, nice improvement. > > +1(binding) > > Best

[RESULT][VOTE] FLIP-451: Introduce timeout configuration to AsyncSink

2024-05-22 Thread Ahmed Hamdy
https://lists.apache.org/thread/9mkzdv0gzssxh8p0y1cl3dvj6lvwyrc0 Best Regards Ahmed Hamdy

Re: [DISCUSS] Add Flink CDC Channel to Apache Flink Slack Workspace

2024-05-29 Thread Ahmed Hamdy
Thanks Zhongqiang, +1 for sure. Best Regards Ahmed Hamdy On Wed, 29 May 2024 at 13:48, ConradJam wrote: > +1 best > > Hang Ruan 于2024年5月29日周三 11:28写道: > > > Hi, zhongqiang. > > > > Thanks for the proposal. +1 for it. > > > > Best, > >

Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo

2024-06-04 Thread Ahmed Hamdy
Congratulations Weijie Best Regards Ahmed Hamdy On Tue, 4 Jun 2024 at 10:51, Matthias Pohl wrote: > Congratulations, Weijie! > > Matthias > > On Tue, Jun 4, 2024 at 11:12 AM Guowei Ma wrote: > > > Congratulations! > > > > Best, > > Guowei

Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector

2024-06-07 Thread Ahmed Hamdy
k-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java#L227 3-https://issues.apache.org/jira/browse/FLINK-35541 Best Regards Ahmed Hamdy On Thu, 6 Jun 2024 at 06:53, Mingliang Liu wrote: > Hi all, > > Currently the Elasticsearch 8 connec

Re: [DISCUSS] FLIP-299 Pub/Sub Lite Connector

2024-06-08 Thread Ahmed Hamdy
int of the discussion at the moment. I would love to hear your thoughts. 1-https://lists.apache.org/thread/63wdvo5hvr6koc3wzbqy2kw4krhmkfbx Best Regards Ahmed Hamdy On Fri, 17 Mar 2023 at 15:58, Daniel Collins wrote: > > would the repository ... be removed ... ? > > Yes, I would remov

Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-08 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Sat, 8 Jun 2024 at 22:26, Jeyhun Karimov wrote: > Hi Yuxin, > > Thanks for driving this. > +1 (non-binding) > > Regards, > Jeyhun > > On Fri, Jun 7, 2024 at 6:05 PM Jim Hughes > wrote: > > > HI all,

Re: [VOTE] Release 1.19.1, release candidate #1

2024-06-08 Thread Ahmed Hamdy
Hi Hong, Thanks for driving +1 (non-binding) - Verified signatures and hashes - Checked github release tag - Verified licenses - Checked that the source code does not contain binaries - Reviewed Web PR, nit: Could we address the comment of adding FLINK-34633 in the release Best Regards Ahmed

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

2024-06-10 Thread Ahmed Hamdy
Congratulations Rui! Best Regards Ahmed Hamdy On Mon, 10 Jun 2024 at 09:10, David Radley wrote: > Congratulations, Rui! > > From: Sergey Nuyanzin > Date: Sunday, 9 June 2024 at 20:33 > To: dev@flink.apache.org > Subject: [EXTERNAL] Re: [ANNOUNCE] New Apache Flink PM

Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector

2024-06-11 Thread Ahmed Hamdy
Hi Mingliang, Yes sounds like a good solution, I am not very familiar with ElasticSearch internals and APIs but will try to assist with the PR when ready. Best Regards Ahmed Hamdy On Tue, 11 Jun 2024 at 07:07, Mingliang Liu wrote: > Thank you Ahmed for the explanation. > > Th

Re: [DISCUSS] Connector Externalization Retrospective

2024-06-11 Thread Ahmed Hamdy
hnical debt and removing it would be an Adhoc task for maintainers which I believe is an accepted tradeoff but would love to hear the feedback. 1- https://github.com/apache/flink/pull/24180/files#diff-2ffade463560e5941912b91b12a07c888313a4cc7e39ca8700398ed6975b8e90 Best Regards Ahmed Hamdy On Tue, 11

Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan

2024-06-17 Thread Ahmed Hamdy
Congratulations Hang. Regards Ahmed On Mon, 17 Jun 2024, 14:01 Feifan Wang, wrote: > Congratulations Hang ! > > > —— > > Best regards, > > Feifan Wang > > > > > At 2024-06-17 11:17:13, "Leonard Xu" wrote: > >Hi everyone, > >On behalf of the PMC, I'm happy to let you know that Hang R

Re: Flink Kinesis Connector GetRecords Frequency

2022-05-25 Thread Ahmed Hamdy
figure FlinkKinesisConsumer for a certain GetRecords limit. Regards Ahmed Hamdy On Wed, 25 May 2022 at 10:44, Aqib Mehmood wrote: > Dear Support Team, > > We were setting up a Kinesis-Flink pipeline on our cluster and we seem to > be running into an issue. > > It seems th

Re: [ANNOUNCE] New Apache Flink PMC Member - Danny Cranmer

2022-10-10 Thread Ahmed Hamdy
Congratulations Danny! Ahmed On Mon, 10 Oct 2022, 08:12 Teoh, Hong, wrote: > Congratulations Danny! > > Hong > > On 10/10/2022, 08:06, "Robert Metzger" wrote: > > CAUTION: This email originated from outside of the organization. Do > not click links or open attachments unless you can confir

Re: [VOTE] Dedicated AWS externalized connector repo

2022-10-28 Thread Ahmed Hamdy
+1 (non-binding) Regards, Ahmed On Thu, 27 Oct 2022 at 08:38, Teoh, Hong wrote: > +1 (non-binding) > > Thanks for driving this, Danny! > > Hong > > On 26/10/2022, 08:14, "Martijn Visser" wrote: > > CAUTION: This email originated from outside of the organization. Do > not click links or ope

Re: [VOTE] FLIP-444: Native file copy support

2024-06-27 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Thu, 27 Jun 2024 at 17:29, Martijn Visser wrote: > +1 (binding) > > On Thu, Jun 27, 2024 at 3:32 AM Rui Fan <1996fan...@gmail.com> wrote: > > > +1(binding) > > > > Best, > > Rui > > > > On W

Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released

2024-06-27 Thread Ahmed Hamdy
Congratulations, Thanks for the efforts Best Regards Ahmed Hamdy On Thu, 20 Jun 2024 at 12:57, Muhammet Orazov wrote: > Great, thanks Qingsheng for your efforts! > > Best, > Muhammet > > On 2024-06-18 15:50, Qingsheng Ren wrote: > > The Apache Flink community is ve

Re: [DISCUSS] FLIP-299 Pub/Sub Lite Connector

2024-07-02 Thread Ahmed Hamdy
Hi Martijn, yes, I agree, thanks for confirmation. Best Regards Ahmed Hamdy On Tue, 2 Jul 2024 at 12:30, Martijn Visser wrote: > Hi, > > Since PubSub Lite is deprecated, I think we can safely close this FLIP and > not proceed further [1] > > Best regards, > &g

Re: [VOTE] FLIP-460: Display source/sink I/O metrics on Flink Web UI

2024-07-16 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Tue, 16 Jul 2024 at 21:58, Becket Qin wrote: > +1 (binding) > > Thanks, > > Jiangjie (Becket) Qin > > On Tue, Jul 16, 2024 at 12:19 AM Leonard Xu wrote: > > > +1(binding) > > > > Best, > > Leonar

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-07-27 Thread Ahmed Hamdy
P-438 implementation but I echo the fact that there might be some reusable code between the 2 submodules we should make use of. Best Regards Ahmed Hamdy On Fri, 26 Jul 2024 at 17:55, Saurabh Singh wrote: > Hi Li Wang, > > Thanks for the review and appreciate your feedback. > I comple

Re: [VOTE] Release 1.20.0, release candidate #2

2024-07-29 Thread Ahmed Hamdy
Thanks Weijie for driving +1 (non-binding) - Verified checksums - Verified signature matches Rui Fan's - Verified tag exists on Github - Build from source - Verified no binaries in source archive - Reviewed release notes PR (some nits) Best Regards Ahmed Hamdy On Thu, 25 Jul 2024 at

Re: [ANNOUNCE] Apache Flink 1.20.0 released

2024-08-02 Thread Ahmed Hamdy
Congratulations! Thanks Weijie and the release managers for the huge efforts. Best Regards Ahmed Hamdy On Fri, 2 Aug 2024 at 10:15, Zakelly Lan wrote: > Congratulations! Thanks to release managers and everyone involved! > > > Best, > Zakelly > > On Fri, Aug 2, 2024

Re: Discussion on Vertica-Flink Connector

2024-08-05 Thread Ahmed Hamdy
Hi Vikas, Could you address feedback from Yanquan, we can create the FLIP page later. Best Regards Ahmed Hamdy On Mon, 5 Aug 2024 at 07:17, Vikas Garg wrote: > Hello, > > We are looking forward to creating FLIP for voting. Can someone help me > with creating the FLIP since now w

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-08-07 Thread Ahmed Hamdy
ments. Thanks again for the effort. Best Regards Ahmed Hamdy On Wed, 31 Jul 2024 at 10:34, Saurabh Singh wrote: > Hi Ahmed, > > Thank you very much for the detailed, valuable review. Please find our > responses below: > > >- In the FLIP you mention the split is goi

Re: [DISCUSS] Release flink-connector-mongodb 2.0.0

2024-08-09 Thread Ahmed Hamdy
Hi Jiabao, Thanks for raising this, +1 for the proposal. Best Regards Ahmed Hamdy On Thu, 8 Aug 2024 at 10:33, Leonard Xu wrote: > Thanks Jiabao for kicking off this thread, +1 for the proposal. > > > Feel free to ping me if you need help from PMC member side. > > Best, >

Re: [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink

2024-08-12 Thread Ahmed Hamdy
Hi Rich, I see the ticket is already stale-assigned. Feel free to raise another PR with your contribution. Best Regards Ahmed Hamdy On Sun, 11 Aug 2024 at 04:26, Rich C. wrote: > Hi all, > > I'm reaching out to you about FLINK-28842 > <https://issues.apache.org/jira/browse

Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests

2024-08-15 Thread Ahmed Hamdy
+1 (non-binding) Thanks for driving. Best Regards Ahmed Hamdy On Wed, 14 Aug 2024 at 07:33, Xuyang wrote: > +1 (non-binding) > > > -- > > Best! > Xuyang > > > > > > 在 2024-08-14 11:04:18,"Yuepeng Pan" 写道: > > > > >

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-08-20 Thread Ahmed Hamdy
Hi Abhisagar and Saurabh I have created the FLIP page and assigned it FLIP-477[1]. Feel free to resume with the next steps. 1- https://cwiki.apache.org/confluence/display/FLINK/FLIP-+477+Amazon+SQS+Source+Connector Best Regards Ahmed Hamdy On Tue, 20 Aug 2024 at 06:05, Abhisagar Khatri wrote

Re: [VOTE] FLIP-477: Amazon SQS Source Connector

2024-08-21 Thread Ahmed Hamdy
Thanks for driving Abhisagar, +1 (non-binding) Best Regards Ahmed Hamdy On Wed, 21 Aug 2024 at 09:11, Abhisagar Khatri wrote: > Hi Flink Devs, > > Thank you for all the feedback about FLIP-477: Amazon SQS Source Connector > [1]. The discussion thread can be found here [2]. >

Re: [ANNOUNCE] Apache Flink CDC 3.2.0 released

2024-09-10 Thread Ahmed Hamdy
Great Milestone for the CDC project. Thanks Qingsheng and the team for the efforts. Best Regards Ahmed Hamdy On Thu, 5 Sept 2024 at 15:03, Muhammet Orazov wrote: > Amazing! > > Thanks Qingsheng and everyone for your efforts! > > Best, > Muhammet > > > On 2024-09-05

[DISCUSS] Elasticsearch v3.1 release

2024-10-14 Thread Ahmed Hamdy
://issues.apache.org/jira/browse/FLINK-34113 3-https://issues.apache.org/jira/browse/FLINK-26088 Best Regards Ahmed Hamdy

Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1

2024-10-12 Thread Ahmed Hamdy
miss something? Best Regards Ahmed Hamdy On Sat, 12 Oct 2024 at 05:23, Yanquan Lv wrote: > +1 (non-binding) > I checked: > - Review JIRA release notes > - Verify hashes > - Verify signatures > - Build from source with JDK 8/11/17 > - Source code artifacts matching the current rele

Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1

2024-10-14 Thread Ahmed Hamdy
Hi Arvid, yeah sure, thanks for following up Best Regards Ahmed Hamdy On Mon, 14 Oct 2024 at 10:52, Danny Cranmer wrote: > Hey Arvid, > > +1 (binding) > > - I left a couple of comments on the website PR that need addressing > - Release notes look good > - Source a

Re: [DISCUSS] Elasticsearch v3.1 release

2024-10-29 Thread Ahmed Hamdy
Thanks Danny for the input, I figured out most of the steps require committer permissions, I will reach out offline for the next steps so thanks in advance for the assistance also. Best Regards Ahmed Hamdy On Mon, 14 Oct 2024 at 17:23, Danny Cranmer wrote: > Hey Ahmed, > > +1 for th

Re: Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li

2024-11-06 Thread Ahmed Hamdy
Congratulations Junrui! Best Regards Ahmed Hamdy On Wed, 6 Nov 2024 at 08:32, Xuyang wrote: > Congratulations, Junrui! > > > -- > > Best! > Xuyang > > > > > > 在 2024-11-06 14:34:36,"Yuepeng Pan" 写道: > >Congratulations! > >

Re: [DISCUSS] Flink PubSub connector bump release needed

2024-11-08 Thread Ahmed Hamdy
to start a new minor version release to land the new Sink to users like yourself. Looking forward to the feedback from the community as well. Best Regards Ahmed Hamdy On Fri, 8 Nov 2024 at 07:48, Radek Stankiewicz wrote: > Dear Flink devs, I would like to initiate a discussion about the nee

Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3

2024-11-08 Thread Ahmed Hamdy
Thanks Hong for driving, +1 (non-binding) - Release notes look good - Verified there are no blocker issues. - Verified signatures and hashsums - No binaries in source - Build source using maven and jdk11 - Verified tag is present in repo Best Regards Ahmed Hamdy On Fri, 8 Nov 2024 at 02:28

Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1

2024-11-25 Thread Ahmed Hamdy
+1 (non-binding) - Validated hashes & checksums - Validated signatures - Verified no binaries in source archive - Build source with maven Best Regards Ahmed Hamdy On Mon, 25 Nov 2024 at 08:50, Martijn Visser wrote: > +1 (binding) > > - Validated hashes > - Verified signat

Re: [DISCUSS] Elasticsearch v3.1 release

2024-12-03 Thread Ahmed Hamdy
Hi Yanquan, I have kicked off the release process for v3.1, will try to conclude soon and announce. Sorry for the delays, it is quite hard to process the release without PMC permissions but Danny is kindly offering help when needed. Best Regards Ahmed Hamdy On Tue, 3 Dec 2024 at 12:05, Yanquan

Re: [VOTE] CHI: Stale PR cleanup

2025-01-07 Thread Ahmed Hamdy
Thanks Tom +1 (non-binding) Best Regards Ahmed Hamdy On Mon, 6 Jan 2025 at 16:43, David Radley wrote: > Thanks for driving this Tom. > +1 (non-binding) > David > > From: Gyula Fóra > Date: Monday, 6 January 2025 at 16:33 > To: dev@flink.apache.org > Subject: [EXTERNA

Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.

2024-12-29 Thread Ahmed Hamdy
lelism change? 1- https://issues.apache.org/jira/browse/FLINK-31762 Best Regards Ahmed Hamdy On Fri, 27 Dec 2024 at 06:38, Hongshun Wang wrote: > Hi devs, > > I'd like to push a new FLIP xxx: Kafka Enumerator assigns splits based on > the current assignment situation. Curren

Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation.

2024-12-30 Thread Ahmed Hamdy
nsider a simpler approach, like just a round-robin assignment for all topic/partitions instead of hash based topic assignment + round-robin partition? I am sorry if the discussion is getting more detailed, happy to move it to a FLIP if the community agrees as well. Best Regards Ahmed Hamdy On

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

2025-02-12 Thread Ahmed Hamdy
ng it more "bufferHandler" rather than a "batchCreator", let me know your thoughts about this. Best Regards Ahmed Hamdy On Tue, 11 Feb 2025 at 10:45, Poorvank Bhatia wrote: > Hey everyone, > > I’d like to propose adding a pluggable batching mechanism to > AsyncSinkWr

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-16 Thread Ahmed Hamdy
Hi Sergey, +1 for restarting this. Best Regards Ahmed Hamdy On Thu, 16 Jan 2025 at 14:02, David Radley wrote: > Hi Sergey, > I think this makes a lot of sense to get this cleared up soon. > I notice that there is a HiveCatalog referred to in the Python in core > Flink. I

Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector

2025-04-07 Thread Ahmed Hamdy
uggesting we identify the poison pills? I am personally in favor of global failures in this case but would love to hear the feedback here. Best Regards Ahmed Hamdy On Mon, 7 Apr 2025 at 11:29, Wong, Daren wrote: > Hi Dev, > > I would like to start a d

Re: [VOTE] FLIP-513: Split-level watermark metrics

2025-03-17 Thread Ahmed Hamdy
+1 (non-binding) Thanks for the proposal Best Regards Ahmed Hamdy On Mon, 17 Mar 2025 at 13:28, Roman Khachatryan wrote: > +1 (binding) > > Regards, > Roman > > > On Mon, Mar 17, 2025 at 11:06 AM Efrat Levitan > wrote: > > > Hi everyone, > > > >

Re: KinesisStreamSource de-aggregation support via DeserializationSchema

2025-04-29 Thread Ahmed Hamdy
not rush any workaround in the apache AWS connectors repo but rather push for a release once the feature is merged. Best Regards Ahmed Hamdy On Mon, 28 Apr 2025 at 17:22, Lorenzo Nicora wrote: > Hello > the current version of Kinesis source (5.0.0) lacks support for KLP > de-aggre

Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink

2025-03-12 Thread Ahmed Hamdy
Thanks for addressing the feedback Poorvank, +1 (non-binding) Best Regards Ahmed Hamdy On Tue, 11 Mar 2025 at 11:32, Doğuşcan Namal wrote: > Thanks for the FLIP Poorvank. We already had a discussion on the Google doc > and thanks for addressing the comments. > > It looks good as

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

2025-02-13 Thread Ahmed Hamdy
FYI: Created FLIP-509. Best Regards Ahmed Hamdy On Thu, 13 Feb 2025 at 16:30, Ahmed Hamdy wrote: > Hi Poorvank, > thanks for the feedback, I can see your point and I kinda agree, I would > say, if you don't need the flushing trigger interface in your use case > let's k

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

2025-02-13 Thread Ahmed Hamdy
and assign it a number. Best Regards Ahmed Hamdy On Thu, 13 Feb 2025 at 09:15, Poorvank Bhatia wrote: > Hello Ahmed, > Thank you for your insights! In fact, FLIP-284 > < > https://cwiki.apache.org/confluence/display/FLINK/FLIP-284+%3A+Making+AsyncSinkWriter+Flush+triggers+adjusta

Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector

2025-03-28 Thread Ahmed Hamdy
+1 (non-binding) Thanks Arvid Best Regards Ahmed Hamdy On Thu, 27 Mar 2025 at 16:11, Aleksandr Savonin wrote: > +1 (non-binding) > > On Thu, 27 Mar 2025 at 15:32, Piotr Nowojski wrote: > > > +1 (binding) > > > > czw., 27 mar 2025 o 15:23 Gyula Fóra nap

[DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API

2025-07-18 Thread Ahmed Hamdy
wiki.apache.org/confluence/display/FLINK/FLIP-536%3A+Add+latest+checkpoint+details+endpoint+to+Rest+API Best Regards Ahmed Hamdy

Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API

2025-07-18 Thread Ahmed Hamdy
well as the rest of the community. Best Regards Ahmed Hamdy On Fri, 18 Jul 2025 at 16:47, David Radley wrote: > Hi Ahmed, > Thanks for submitting this Flip. > What do you think of having /jobs/:jobid/checkpoints with query params to > specify sorted criteria and direction and the numb

Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API

2025-07-21 Thread Ahmed Hamdy
might be useful in some cases. Best Regards Ahmed Hamdy On Fri, 18 Jul 2025 at 20:39, Poorvank Bhatia wrote: > Hi Ahmed, Thank you for the FLIP. > +1 (non-binding) for this feature. > > I have two implementation questions: > >1. Approach for finding latest checkpoints:

Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API

2025-07-25 Thread Ahmed Hamdy
t:{...checkpoint info...}" suggestion. will only need to wrap the details. > The FLIP should also cover the error cases when it is called for jobs that don't have checkpointing enabled (e.g., batch). will add to the FLIP but I guess we should just go with a 400 response Best Regards Ahmed Ha

[jira] [Created] (FLINK-31998) Flink Operator Deadlock on run job Failure

2023-05-04 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-31998: --- Summary: Flink Operator Deadlock on run job Failure Key: FLINK-31998 URL: https://issues.apache.org/jira/browse/FLINK-31998 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector

2023-05-04 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-32007: --- Summary: Implement Python Wrappers for DynamoDB Connector Key: FLINK-32007 URL: https://issues.apache.org/jira/browse/FLINK-32007 Project: Flink Issue Type

[jira] [Created] (FLINK-32063) AWS CI mvn compile fails to cast objects to parent type.

2023-05-11 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-32063: --- Summary: AWS CI mvn compile fails to cast objects to parent type. Key: FLINK-32063 URL: https://issues.apache.org/jira/browse/FLINK-32063 Project: Flink Issue

[jira] [Created] (FLINK-31772) AsyncSinkWriter Performance regression due to AIMD rate limiting strategy

2023-04-11 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-31772: --- Summary: AsyncSinkWriter Performance regression due to AIMD rate limiting strategy Key: FLINK-31772 URL: https://issues.apache.org/jira/browse/FLINK-31772 Project

[jira] [Created] (FLINK-31872) CLONE - AsyncSinkWriter Performance regression due to AIMD rate limiting strategy

2023-04-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-31872: --- Summary: CLONE - AsyncSinkWriter Performance regression due to AIMD rate limiting strategy Key: FLINK-31872 URL: https://issues.apache.org/jira/browse/FLINK-31872

[jira] [Created] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink

2024-04-06 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35022: --- Summary: Add TypeInformed Element Converter for DynamoDbSink Key: FLINK-35022 URL: https://issues.apache.org/jira/browse/FLINK-35022 Project: Flink Issue Type

[jira] [Created] (FLINK-35050) Remove Lazy Initialization of DynamoDbBeanElementConverter

2024-04-08 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35050: --- Summary: Remove Lazy Initialization of DynamoDbBeanElementConverter Key: FLINK-35050 URL: https://issues.apache.org/jira/browse/FLINK-35050 Project: Flink

[jira] [Created] (FLINK-35320) RabbitMQ Source fails to consume from quorum queues when prefetch Count is set

2024-05-09 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35320: --- Summary: RabbitMQ Source fails to consume from quorum queues when prefetch Count is set Key: FLINK-35320 URL: https://issues.apache.org/jira/browse/FLINK-35320 Project

[jira] [Created] (FLINK-35322) PubSub Connector Weekly build fails

2024-05-09 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35322: --- Summary: PubSub Connector Weekly build fails Key: FLINK-35322 URL: https://issues.apache.org/jira/browse/FLINK-35322 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35401) Add SQS Table API support

2024-05-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35401: --- Summary: Add SQS Table API support Key: FLINK-35401 URL: https://issues.apache.org/jira/browse/FLINK-35401 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-05-23 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35435: --- Summary: [FLIP-451] Introduce timeout configuration to AsyncSink Key: FLINK-35435 URL: https://issues.apache.org/jira/browse/FLINK-35435 Project: Flink Issue

[jira] [Created] (FLINK-35445) Update Async Sink documentation for Timeout configuration

2024-05-24 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35445: --- Summary: Update Async Sink documentation for Timeout configuration Key: FLINK-35445 URL: https://issues.apache.org/jira/browse/FLINK-35445 Project: Flink

[jira] [Created] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions

2024-05-26 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35454: --- Summary: Connector ArchTests fails due to dependency on fink.util.Preconditions Key: FLINK-35454 URL: https://issues.apache.org/jira/browse/FLINK-35454 Project: Flink

[jira] [Created] (FLINK-35500) DynamoDb SinkWriter fails to delete elements due to key not found

2024-05-31 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35500: --- Summary: DynamoDb SinkWriter fails to delete elements due to key not found Key: FLINK-35500 URL: https://issues.apache.org/jira/browse/FLINK-35500 Project: Flink

[jira] [Created] (FLINK-35548) Add E2E tests for PubSubSinkV2

2024-06-07 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35548: --- Summary: Add E2E tests for PubSubSinkV2 Key: FLINK-35548 URL: https://issues.apache.org/jira/browse/FLINK-35548 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27756) Fix Intermittingly failing test in `AsyncSinkWriterTest`

2022-05-24 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-27756: --- Summary: Fix Intermittingly failing test in `AsyncSinkWriterTest` Key: FLINK-27756 URL: https://issues.apache.org/jira/browse/FLINK-27756 Project: Flink Issue

[jira] [Created] (FLINK-25610) [FLIP-171] Kinesis Firehose implementation of Async Sink Table API

2022-01-11 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25610: --- Summary: [FLIP-171] Kinesis Firehose implementation of Async Sink Table API Key: FLINK-25610 URL: https://issues.apache.org/jira/browse/FLINK-25610 Project: Flink

[jira] [Created] (FLINK-25733) [FLIP-171] Create A migration guide for Kinesis Table API connector

2022-01-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25733: --- Summary: [FLIP-171] Create A migration guide for Kinesis Table API connector Key: FLINK-25733 URL: https://issues.apache.org/jira/browse/FLINK-25733 Project: Flink

[jira] [Created] (FLINK-25734) Chinese Translation - Update documentation for Kinesis Table Api

2022-01-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25734: --- Summary: Chinese Translation - Update documentation for Kinesis Table Api Key: FLINK-25734 URL: https://issues.apache.org/jira/browse/FLINK-25734 Project: Flink

[jira] [Created] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams.

2022-01-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25810: --- Summary: [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams. Key: FLINK-25810 URL: https://issues.apache.org/jira/browse/FLINK-25810 Project: Flink

[jira] [Created] (FLINK-25811) Fix generic AsyncSinkWriter retrying requests in reverse order

2022-01-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25811: --- Summary: Fix generic AsyncSinkWriter retrying requests in reverse order Key: FLINK-25811 URL: https://issues.apache.org/jira/browse/FLINK-25811 Project: Flink

[jira] [Created] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

2022-02-03 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25949: --- Summary: [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol. Key: FLINK-25949 URL: https://issues.apache.org/jira/browse/FLINK-25949 Project

[jira] [Created] (FLINK-26056) CLONE - [FLIP-171] KDS implementation of Async Sink Table API

2022-02-09 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26056: --- Summary: CLONE - [FLIP-171] KDS implementation of Async Sink Table API Key: FLINK-26056 URL: https://issues.apache.org/jira/browse/FLINK-26056 Project: Flink

[jira] [Created] (FLINK-26057) CLONE - [FLIP-171] Add SQL Client Uber jar for KinesisDataStreams Sink.

2022-02-09 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26057: --- Summary: CLONE - [FLIP-171] Add SQL Client Uber jar for KinesisDataStreams Sink. Key: FLINK-26057 URL: https://issues.apache.org/jira/browse/FLINK-26057 Project: Flink

[jira] [Created] (FLINK-26058) KinesisDynamicTableFactory implements DynamicSourceFactory but uses sink options

2022-02-09 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26058: --- Summary: KinesisDynamicTableFactory implements DynamicSourceFactory but uses sink options Key: FLINK-26058 URL: https://issues.apache.org/jira/browse/FLINK-26058

[jira] [Created] (FLINK-26310) [FLIP-171] Add AsyncSinkWriterConfig class

2022-02-22 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26310: --- Summary: [FLIP-171] Add AsyncSinkWriterConfig class Key: FLINK-26310 URL: https://issues.apache.org/jira/browse/FLINK-26310 Project: Flink Issue Type

[jira] [Created] (FLINK-26373) Rename flink-connector-aws-kinesis-data-streams module to flink-connector-aws-kinesis-streams

2022-02-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26373: --- Summary: Rename flink-connector-aws-kinesis-data-streams module to flink-connector-aws-kinesis-streams Key: FLINK-26373 URL: https://issues.apache.org/jira/browse/FLINK-26373

[jira] [Created] (FLINK-26397) Chinese Translation - Add documentation for Kinesis firehose Table Api

2022-02-28 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26397: --- Summary: Chinese Translation - Add documentation for Kinesis firehose Table Api Key: FLINK-26397 URL: https://issues.apache.org/jira/browse/FLINK-26397 Project: Flink

[jira] [Created] (FLINK-26398) Add documentation for Kinesis Firehose table API.

2022-02-28 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-26398: --- Summary: Add documentation for Kinesis Firehose table API. Key: FLINK-26398 URL: https://issues.apache.org/jira/browse/FLINK-26398 Project: Flink Issue Type

[jira] [Created] (FLINK-28332) GlueSchemaRegistryJsonKinesisITCase is being Ignored due to `Access key not configured`

2022-06-30 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-28332: --- Summary: GlueSchemaRegistryJsonKinesisITCase is being Ignored due to `Access key not configured` Key: FLINK-28332 URL: https://issues.apache.org/jira/browse/FLINK-28332

[jira] [Created] (FLINK-28333) GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `Access key not configured`

2022-06-30 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-28333: --- Summary: GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `Access key not configured` Key: FLINK-28333 URL: https://issues.apache.org/jira/browse/FLINK-28333

[jira] [Created] (FLINK-35697) Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink

2024-06-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35697: --- Summary: Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink Key: FLINK-35697 URL: https://issues.apache.org/jira/browse/FLINK-35697 Project

[jira] [Created] (FLINK-35779) Update documentation for PubSubSinkV2

2024-07-07 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35779: --- Summary: Update documentation for PubSubSinkV2 Key: FLINK-35779 URL: https://issues.apache.org/jira/browse/FLINK-35779 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED

2024-08-08 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36010: --- Summary: Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED Key: FLINK-36010 URL: https://issues.apache.org/jira/browse/FLINK-36010

[jira] [Created] (FLINK-36077) Implement Table API support for PubSubSink V2

2024-08-16 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36077: --- Summary: Implement Table API support for PubSubSink V2 Key: FLINK-36077 URL: https://issues.apache.org/jira/browse/FLINK-36077 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-36078) Add Documentation for PubSubSink Table API connector

2024-08-16 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36078: --- Summary: Add Documentation for PubSubSink Table API connector Key: FLINK-36078 URL: https://issues.apache.org/jira/browse/FLINK-36078 Project: Flink Issue

[jira] [Created] (FLINK-36079) Add Documentation for SQS Table API connector

2024-08-17 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36079: --- Summary: Add Documentation for SQS Table API connector Key: FLINK-36079 URL: https://issues.apache.org/jira/browse/FLINK-36079 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-36080) Add SQL Connector for SQS

2024-08-17 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36080: --- Summary: Add SQL Connector for SQS Key: FLINK-36080 URL: https://issues.apache.org/jira/browse/FLINK-36080 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector

2024-11-02 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36651: --- Summary: Fix CI tests for ElasticSearch Connector Key: FLINK-36651 URL: https://issues.apache.org/jira/browse/FLINK-36651 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36972) Unify AWS sink implementation

2024-12-27 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36972: --- Summary: Unify AWS sink implementation Key: FLINK-36972 URL: https://issues.apache.org/jira/browse/FLINK-36972 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-36971) Add Sqs Sink SQL connector

2024-12-27 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-36971: --- Summary: Add Sqs Sink SQL connector Key: FLINK-36971 URL: https://issues.apache.org/jira/browse/FLINK-36971 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37258) Order Flink Job list in Flink UI with start time

2025-02-05 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-37258: --- Summary: Order Flink Job list in Flink UI with start time Key: FLINK-37258 URL: https://issues.apache.org/jira/browse/FLINK-37258 Project: Flink Issue Type

<    1   2   3   >