[RESULT][VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Feng Jin
Hi devs, I'm happy to announce that FLIP-387: Support named parameters for functions and call procedures [1] [2] has been accepted with 6 approving votes (4 binding) - Benchao Li (binding) - Lincoln Lee (binding) - Timo Walther (binding) - Xuyang (non-binding) - Jingsong Li (binding) -

Re: [DISCUSS] FLIP-406: Reorganize State & Checkpointing & Recovery Configuration

2024-01-09 Thread Zakelly Lan
Hi Hangxiang, Thanks for your suggestions! 1. Could execution.recovery also contain some other behaviors about > recovery ? e.g. restart-strategy. That's a very good point. I realize that the word 'recovery' means way too many things. So I suggest picking a more specific word here, how about

Re: Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Feng Jin
Thank you all! Closing the vote. The result will be sent in a separate email. Best, Feng Jin On Wed, Jan 10, 2024 at 2:04 PM Hang Ruan wrote: > +1 (non-binding) > > Best, > Hang > > Jingsong Li 于2024年1月10日周三 12:03写道: > > > +1 > > > > On Wed, Jan 10, 2024 at 11:24 AM Xuyang wrote: > > > > > >

Re: Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Hang Ruan
+1 (non-binding) Best, Hang Jingsong Li 于2024年1月10日周三 12:03写道: > +1 > > On Wed, Jan 10, 2024 at 11:24 AM Xuyang wrote: > > > > +1(non-binding)-- > > > > Best! > > Xuyang > > > > > > > > > > > > 在 2024-01-08 00:34:55,"Feng Jin" 写道: > > >Hi Alexey > > > > > >Thank you for the reminder,

Re: Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Jingsong Li
+1 On Wed, Jan 10, 2024 at 11:24 AM Xuyang wrote: > > +1(non-binding)-- > > Best! > Xuyang > > > > > > 在 2024-01-08 00:34:55,"Feng Jin" 写道: > >Hi Alexey > > > >Thank you for the reminder, the link has been updated. > > > >Best, > >Feng Jin > > > >On Sat, Jan 6, 2024 at 12:55 AM Alexey

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Xingbo Huang
+1 (binding) Best, Xingbo Dian Fu 于2024年1月10日周三 11:35写道: > +1 (binding) > > Regards, > Dian > > On Wed, Jan 10, 2024 at 5:09 AM Sharath wrote: > > > > +1 (non-binding) > > > > Best, > > Sharath > > > > On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla < > sanath...@gmail.com> > > wrote:

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Dian Fu
+1 (binding) Regards, Dian On Wed, Jan 10, 2024 at 5:09 AM Sharath wrote: > > +1 (non-binding) > > Best, > Sharath > > On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla > wrote: > > > +1 (non-binding) > > > > Thanks, > > Sanath > > > > On Tue, Jan 9, 2024 at 11:16 AM Peter Huang > >

Re:Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

2024-01-09 Thread Xuyang
+1(non-binding)-- Best! Xuyang 在 2024-01-08 00:34:55,"Feng Jin" 写道: >Hi Alexey > >Thank you for the reminder, the link has been updated. > >Best, >Feng Jin > >On Sat, Jan 6, 2024 at 12:55 AM Alexey Leonov-Vendrovskiy < >vendrov...@gmail.com> wrote: > >> Thanks for starting the vote!

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

2024-01-09 Thread Qingsheng Ren
+1 (binding) - Built from source - Verified checksum and signature - Verified that no binary exist in source - Started a standalone cluster and submit Kafka consuming and producing job with SQL client - Reviewed web PR Thanks for driving this, Jing! Best, Qingsheng On Mon, Jan 8, 2024 at 8:02 

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-09 Thread Zhanghao Chen
Hi David, Thanks for the comments. AFAIK, unaligned checkpoints are disabled for pointwise connections according to [1], let's wait Piotr for confirmation. The issue itself is not directly related to this proposal as well. If a user manually specifies UIDs for each of the chained operators and

Re: [DISCUSS] FLIP-329: Add operator attribute to specify support for object-reuse

2024-01-09 Thread Xuannan Su
Hi Lu, You can find information about the FLIP process on our wiki[1]. Please let me know if you have any questions. Best regards, Xuannan [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals On Tue, Jan 9, 2024 at 5:36 AM Lu Niu wrote: > > sounds good. Is the

[jira] [Created] (FLINK-34046) Add metrics to AsyncWaitOperator Retry Flow

2024-01-09 Thread Dinesh (Jira)
Dinesh created FLINK-34046: -- Summary: Add metrics to AsyncWaitOperator Retry Flow Key: FLINK-34046 URL: https://issues.apache.org/jira/browse/FLINK-34046 Project: Flink Issue Type: Improvement

Re: FW: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

2024-01-09 Thread David Morávek
Congrats, Alex! Best, D. On Fri, Jan 5, 2024 at 7:25 AM Sergey Nuyanzin wrote: > Congratulations, Alex! > > On Fri, Jan 5, 2024, 05:12 Lincoln Lee wrote: > > > Congratulations, Alex! > > > > Best, > > Lincoln Lee > > > > > > Alexander Fedulov 于2024年1月4日周四 19:08写道: > > > > > Thanks, everyone!

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-09 Thread David Morávek
Hi Zhanghao, Thanks for the FLIP. What you're proposing makes a lot of sense +1 Have you thought about how this works with unaligned checkpoints in case you go from unchained to chained? I think it should be fine because this scenario should only apply to forward/rebalance scenarios where we, as

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Sharath
+1 (non-binding) Best, Sharath On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla wrote: > +1 (non-binding) > > Thanks, > Sanath > > On Tue, Jan 9, 2024 at 11:16 AM Peter Huang > wrote: > > > +1 (non-binding) > > > > > > Best Regards > > Peter Huang > > > > > > On Tue, Jan 9, 2024 at 5:26 

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Venkata Sanath Muppalla
+1 (non-binding) Thanks, Sanath On Tue, Jan 9, 2024 at 11:16 AM Peter Huang wrote: > +1 (non-binding) > > > Best Regards > Peter Huang > > > On Tue, Jan 9, 2024 at 5:26 AM Jane Chan wrote: > > > +1 (non-binding) > > > > Best, > > Jane > > > > On Tue, Jan 9, 2024 at 8:41 PM Lijie Wang > >

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Peter Huang
+1 (non-binding) Best Regards Peter Huang On Tue, Jan 9, 2024 at 5:26 AM Jane Chan wrote: > +1 (non-binding) > > Best, > Jane > > On Tue, Jan 9, 2024 at 8:41 PM Lijie Wang > wrote: > > > +1 (non-binding) > > > > Best, > > Lijie > > > > Jiabao Sun 于2024年1月9日周二 19:28写道: > > > > > +1

[jira] [Created] (FLINK-34045) Add docs generation to workflow

2024-01-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34045: - Summary: Add docs generation to workflow Key: FLINK-34045 URL: https://issues.apache.org/jira/browse/FLINK-34045 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Externalized Python Connector Release/Dependency Process

2024-01-09 Thread Ahmed Hamdy
Hi Danny +1 (non-binding) Best Regards Ahmed Hamdy On Tue, 9 Jan 2024 at 11:59, Xingbo Huang wrote: > Hi Danny, > > +1 > > Thanks a lot for investigating this. Let me share the current code > management and release situation of pyflink here. I hope it will be helpful > to you. > > Since Flink

[jira] [Created] (FLINK-34044) Kinesis Sink Cannot be Created via TableDescriptor

2024-01-09 Thread Tilman Krokotsch (Jira)
Tilman Krokotsch created FLINK-34044: Summary: Kinesis Sink Cannot be Created via TableDescriptor Key: FLINK-34044 URL: https://issues.apache.org/jira/browse/FLINK-34044 Project: Flink

[Jan 26 Feature Freeze][SUMMARY] Flink 1.19 Release Sync 01/09/2024

2024-01-09 Thread Lincoln Lee
Hi devs, Happy New Year! Here's 1st release sync summary of 1.19 in 2024! There're less than 3 weeks until the feature freeze date(Jan 26). - Features & issues tracking So far we've had 27 flips/features and 4 of which have been done. Contributors are encouraged to update the status of

[jira] [Created] (FLINK-34043) Remove deprecated Sink V2 interfaces

2024-01-09 Thread Peter Vary (Jira)
Peter Vary created FLINK-34043: -- Summary: Remove deprecated Sink V2 interfaces Key: FLINK-34043 URL: https://issues.apache.org/jira/browse/FLINK-34043 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34042) Update the documentation

2024-01-09 Thread Peter Vary (Jira)
Peter Vary created FLINK-34042: -- Summary: Update the documentation Key: FLINK-34042 URL: https://issues.apache.org/jira/browse/FLINK-34042 Project: Flink Issue Type: Sub-task

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Jane Chan
+1 (non-binding) Best, Jane On Tue, Jan 9, 2024 at 8:41 PM Lijie Wang wrote: > +1 (non-binding) > > Best, > Lijie > > Jiabao Sun 于2024年1月9日周二 19:28写道: > > > +1 (non-binding) > > > > Best, > > Jiabao > > > > > > On 2024/01/09 09:58:04 xiangyu feng wrote: > > > +1 (non-binding) > > > > > >

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Lijie Wang
+1 (non-binding) Best, Lijie Jiabao Sun 于2024年1月9日周二 19:28写道: > +1 (non-binding) > > Best, > Jiabao > > > On 2024/01/09 09:58:04 xiangyu feng wrote: > > +1 (non-binding) > > > > Regards, > > Xiangyu Feng > > > > Danny Cranmer 于2024年1月9日周二 17:50写道: > > > > > +1 (binding) > > > > > > Thanks, >

Re: [DISCUSS] FLIP-403: High Availability Services for OLAP Scenarios

2024-01-09 Thread Zhu Zhu
> I would treat refactoring as a technical debt... Sorry I don't quite get the needs of the refactoring work. The refactoring work brings benefits if there are requirements to combine different leader election services and persistence services. The answer in this FLIP is to combine

Re: [DISCUSS] Externalized Python Connector Release/Dependency Process

2024-01-09 Thread Xingbo Huang
Hi Danny, +1 Thanks a lot for investigating this. Let me share the current code management and release situation of pyflink here. I hope it will be helpful to you. Since Flink 1.13, release managers need to release two python packages to pypi, apache-flink[1] and apache-flink-libraries[2].

[VOTE] FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-01-09 Thread Jiabao Sun
Hi Devs, I'd like to start a vote on FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources[1] which has been discussed in this thread[2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

RE: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Jiabao Sun
+1 (non-binding) Best, Jiabao On 2024/01/09 09:58:04 xiangyu feng wrote: > +1 (non-binding) > > Regards, > Xiangyu Feng > > Danny Cranmer 于2024年1月9日周二 17:50写道: > > > +1 (binding) > > > > Thanks, > > Danny > > > > On Tue, Jan 9, 2024 at 9:31 AM Feng Jin wrote: > > > > > +1 (non-binding) > >

[jira] [Created] (FLINK-34041) Fix typo in docs/content/docs/deployment/ha/overview.md

2024-01-09 Thread Sumin Kim (Jira)
Sumin Kim created FLINK-34041: - Summary: Fix typo in docs/content/docs/deployment/ha/overview.md Key: FLINK-34041 URL: https://issues.apache.org/jira/browse/FLINK-34041 Project: Flink Issue

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread xiangyu feng
+1 (non-binding) Regards, Xiangyu Feng Danny Cranmer 于2024年1月9日周二 17:50写道: > +1 (binding) > > Thanks, > Danny > > On Tue, Jan 9, 2024 at 9:31 AM Feng Jin wrote: > > > +1 (non-binding) > > > > Best, > > Feng Jin > > > > On Tue, Jan 9, 2024 at 5:29 PM Yuxin Tan wrote: > > > > > +1

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Danny Cranmer
+1 (binding) Thanks, Danny On Tue, Jan 9, 2024 at 9:31 AM Feng Jin wrote: > +1 (non-binding) > > Best, > Feng Jin > > On Tue, Jan 9, 2024 at 5:29 PM Yuxin Tan wrote: > > > +1 (non-binding) > > > > Best, > > Yuxin > > > > > > Márton Balassi 于2024年1月9日周二 17:25写道: > > > > > +1 (binding) > > > >

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Feng Jin
+1 (non-binding) Best, Feng Jin On Tue, Jan 9, 2024 at 5:29 PM Yuxin Tan wrote: > +1 (non-binding) > > Best, > Yuxin > > > Márton Balassi 于2024年1月9日周二 17:25写道: > > > +1 (binding) > > > > On Tue, Jan 9, 2024 at 10:15 AM Leonard Xu wrote: > > > > > +1(binding) > > > > > > Best, > > > Leonard >

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Yuxin Tan
+1 (non-binding) Best, Yuxin Márton Balassi 于2024年1月9日周二 17:25写道: > +1 (binding) > > On Tue, Jan 9, 2024 at 10:15 AM Leonard Xu wrote: > > > +1(binding) > > > > Best, > > Leonard > > > > > 2024年1月9日 下午5:08,Yangze Guo 写道: > > > > > > +1 (non-binding) > > > > > > Best, > > > Yangze Guo > > >

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Márton Balassi
+1 (binding) On Tue, Jan 9, 2024 at 10:15 AM Leonard Xu wrote: > +1(binding) > > Best, > Leonard > > > 2024年1月9日 下午5:08,Yangze Guo 写道: > > > > +1 (non-binding) > > > > Best, > > Yangze Guo > > > > On Tue, Jan 9, 2024 at 5:06 PM Robert Metzger > wrote: > >> > >> +1 (binding) > >> > >> > >> On

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Leonard Xu
+1(binding) Best, Leonard > 2024年1月9日 下午5:08,Yangze Guo 写道: > > +1 (non-binding) > > Best, > Yangze Guo > > On Tue, Jan 9, 2024 at 5:06 PM Robert Metzger wrote: >> >> +1 (binding) >> >> >> On Tue, Jan 9, 2024 at 9:54 AM Guowei Ma wrote: >> >>> +1 (binding) >>> Best, >>> Guowei >>> >>>

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Yangze Guo
+1 (non-binding) Best, Yangze Guo On Tue, Jan 9, 2024 at 5:06 PM Robert Metzger wrote: > > +1 (binding) > > > On Tue, Jan 9, 2024 at 9:54 AM Guowei Ma wrote: > > > +1 (binding) > > Best, > > Guowei > > > > > > On Tue, Jan 9, 2024 at 4:49 PM Rui Fan <1996fan...@gmail.com> wrote: > > > > > +1

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Robert Metzger
+1 (binding) On Tue, Jan 9, 2024 at 9:54 AM Guowei Ma wrote: > +1 (binding) > Best, > Guowei > > > On Tue, Jan 9, 2024 at 4:49 PM Rui Fan <1996fan...@gmail.com> wrote: > > > +1 (non-binding) > > > > Best, > > Rui > > > > On Tue, Jan 9, 2024 at 4:41 PM Hang Ruan wrote: > > > > > +1

[jira] [Created] (FLINK-34040) ScalaSerializersMigrationTest.testStableAnonymousClassnameGeneration fails in GHA with JDK 17 and 21

2024-01-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34040: - Summary: ScalaSerializersMigrationTest.testStableAnonymousClassnameGeneration fails in GHA with JDK 17 and 21 Key: FLINK-34040 URL:

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Guowei Ma
+1 (binding) Best, Guowei On Tue, Jan 9, 2024 at 4:49 PM Rui Fan <1996fan...@gmail.com> wrote: > +1 (non-binding) > > Best, > Rui > > On Tue, Jan 9, 2024 at 4:41 PM Hang Ruan wrote: > > > +1 (non-binding) > > > > Best, > > Hang > > > > gongzhongqiang 于2024年1月9日周二 16:25写道: > > > > > +1

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Yu Li
+1 (binding) Good luck! Best Regards, Yu On Tue, 9 Jan 2024 at 16:49, Rui Fan <1996fan...@gmail.com> wrote: > +1 (non-binding) > > Best, > Rui > > On Tue, Jan 9, 2024 at 4:41 PM Hang Ruan wrote: > > > +1 (non-binding) > > > > Best, > > Hang > > > > gongzhongqiang 于2024年1月9日周二 16:25写道: > > >

Re: Re: FLIP-413: Enable unaligned checkpoints by default

2024-01-09 Thread Piotr Nowojski
Hi! I think this warning from the documentation is a bit over the top. Yes, unaligned checkpoints in that regard are adding an extra source of indeterminism, however please note that Flink doesn't give any guarantees that the results will be the same after a recovery, as the order of the records

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Rui Fan
+1 (non-binding) Best, Rui On Tue, Jan 9, 2024 at 4:41 PM Hang Ruan wrote: > +1 (non-binding) > > Best, > Hang > > gongzhongqiang 于2024年1月9日周二 16:25写道: > > > +1 non-binding > > > > Best, > > Zhongqiang > > > > Leonard Xu 于2024年1月9日周二 15:05写道: > > > > > Hello all, > > > > > > This is the

Re: [DISCUSS][FLINK-31830] Align the Nullability Handling of ROW between SQL and TableAPI

2024-01-09 Thread Dawid Wysakowicz
Hey all, First of all, sorry I have not read the entire thread. I just wanted to make sure you take this one case into consideration. As far as I know, we map java classes to SQL ROWs? E.g. it is possible to have a POJO as a parameter to a UDF. *class MyUDF {* * eval(MyPojo a)* *}* *class

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Hang Ruan
+1 (non-binding) Best, Hang gongzhongqiang 于2024年1月9日周二 16:25写道: > +1 non-binding > > Best, > Zhongqiang > > Leonard Xu 于2024年1月9日周二 15:05写道: > > > Hello all, > > > > This is the official vote whether to accept the Flink CDC code > contribution > > to Apache Flink. > > > > The current Flink

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Samrat Deb
+1 (non binding) Bests, Samrat

[jira] [Created] (FLINK-34039) The session group window agg operator does not split the session window when processing retrace records.

2024-01-09 Thread xuyang (Jira)
xuyang created FLINK-34039: -- Summary: The session group window agg operator does not split the session window when processing retrace records. Key: FLINK-34039 URL: https://issues.apache.org/jira/browse/FLINK-34039

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Lincoln Lee
+1 Best, Lincoln Lee Sergey Nuyanzin 于2024年1月9日周二 16:33写道: > +1 (non-binding) > > On Tue, Jan 9, 2024 at 9:25 AM gongzhongqiang > wrote: > > > +1 non-binding > > > > Best, > > Zhongqiang > > > > Leonard Xu 于2024年1月9日周二 15:05写道: > > > > > Hello all, > > > > > > This is the official vote

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Sergey Nuyanzin
+1 (non-binding) On Tue, Jan 9, 2024 at 9:25 AM gongzhongqiang wrote: > +1 non-binding > > Best, > Zhongqiang > > Leonard Xu 于2024年1月9日周二 15:05写道: > > > Hello all, > > > > This is the official vote whether to accept the Flink CDC code > contribution > > to Apache Flink. > > > > The current

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread gongzhongqiang
+1 non-binding Best, Zhongqiang Leonard Xu 于2024年1月9日周二 15:05写道: > Hello all, > > This is the official vote whether to accept the Flink CDC code contribution > to Apache Flink. > > The current Flink CDC code, documentation, and website can be > found here: > code:

[jira] [Created] (FLINK-34038) IncrementalGroupAggregateRestoreTest.testRestore fails

2024-01-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34038: - Summary: IncrementalGroupAggregateRestoreTest.testRestore fails Key: FLINK-34038 URL: https://issues.apache.org/jira/browse/FLINK-34038 Project: Flink

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Jing Ge
+1 (not binding) Best regards, Jing On Tue, Jan 9, 2024 at 8:46 AM Xintong Song wrote: > +1 (binding) > > Best, > > Xintong > > > > On Tue, Jan 9, 2024 at 3:31 PM Benchao Li wrote: > > > +1 (non-binding) > > > > Feng Wang 于2024年1月9日周二 15:29写道: > > > > > > +1 non-binding > > > Regards, > > >