Re: [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-05-04 Thread Ron Liu
Hi, Lincoln Thanks for join this discussion. After rethinking, I think your suggestion is make sense, although currently deleting the workflow on the Scheduler and relying only on the RefreshHandler is enough, if in the future we support cascading deletion, the DeleteWorkflowOperation can

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

2024-05-04 Thread Ahmed Hamdy
Hi Jeyhun, I have changed the scope of FLIP to exclude problems addressed by FLIP-284 and redefined scope to introduce timeout configuration. Best Regards Ahmed Hamdy On Mon, 29 Apr 2024 at 20:57, Ahmed Hamdy wrote: > Hi Jeyhun, > Thanks for your feedback. I agree the phrasing is a bit

Re: [Vote] FLIP-438: Amazon SQS Sink Connector

2024-05-04 Thread Ahmed Hamdy
Hi Priya, It seems that we have acquired the threshold of binding votes, Should we close the vote, announce the result and create Jiras? Best Regards Ahmed Hamdy On Wed, 17 Apr 2024 at 03:24, Leonard Xu wrote: > +1 (binding) > > Best, > Leonard > > > 2024年4月17日 上午2:25,Robert Metzger 写道: > > >

Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax

2024-05-04 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Sat, 27 Apr 2024 at 02:46, Muhammet Orazov wrote: > > Hey Yubin, +1 (non-binding) > > Looks good, thanks! > > Best, > Muhammet > > On 2024-04-24 08:56, Yubin Li wrote: > > Hi everyone, > > > > During the implementation of the "describe catalog"

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-05-04 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Sat, 27 Apr 2024 at 05:33, ConradJam wrote: > +1 (non-binding) > > Biao Geng 于2024年4月26日周五 18:45写道: > > > +1 (non-binding) > > > > Best, > > Biao Geng > > > > > > gongzhongqiang 于2024年4月26日周五 00:41写道: > > > > > +1( (non-binding) > > > > > > > > >

[jira] [Created] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-04 Thread Kanthi Vaidya (Jira)
Kanthi Vaidya created FLINK-35289: - Summary: Incorrect timestamp of stream elements collected from onTimer in batch mode Key: FLINK-35289 URL: https://issues.apache.org/jira/browse/FLINK-35289

Re: [VOTE] FLIP-454: New Apicurio Avro format

2024-05-04 Thread Ahmed Hamdy
+1 (non-binding) Best Regards Ahmed Hamdy On Fri, 3 May 2024 at 15:16, Jeyhun Karimov wrote: > +1 (non binding) > > Thanks for driving this FLIP David. > > Regards, > Jeyhun > > On Fri, May 3, 2024 at 2:21 PM Mark Nuttall wrote: > > > +1, I would also like to see first class support for Avro

Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1

2024-05-04 Thread Ahmed Hamdy
Hi Qisheng, +1 (non-binding) - Verified checksums and hashes - Verified signatures - Verified github tag exists - Verified no binaries in source - build source Best Regards Ahmed Hamdy On Fri, 3 May 2024 at 23:03, Jeyhun Karimov wrote: > Hi Qinsheng, > > Thanks for driving the release. >

Re: [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction

2024-05-04 Thread Ahmed Hamdy
Hi Martijn Thanks for the proposal +1 from me. Should this change take place in 1.20, what are the planned release steps for connectors that only offer a deprecated interface in this case (i.e. RabbitMQ, Cassandra, pusbub, Hbase)? Are we going to refrain from releases that support 1.20+ till the