Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting

2024-07-31 Thread Stefan Richter
+1 (binding) Best, Stefan > On 31. Jul 2024, at 04:56, Zakelly Lan wrote: > > +1 (binding) > > > Best, > Zakelly > > On Wed, Jul 31, 2024 at 12:07 AM Piotr Nowojski > wrote: > >> Hi all! >> >> I would like to open the vote for FLIP-471 [1]. It has been discussed here >> [2]. >> >> The

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

2024-07-31 Thread Qingsheng Ren
+1 (binding) - Built from source - Reviewed web PR and release note - Verified checksum and signature - Checked GitHub release tag - Tested submitting SQL job with SQL client reading and writing Kafka Best, Qingsheng On Tue, Jul 30, 2024 at 2:26 PM Xintong Song wrote: > +1 (binding) > > - revi

[jira] [Created] (FLINK-35937) Helm RBAC cleanup

2024-07-31 Thread Tim (Jira)
Tim created FLINK-35937: --- Summary: Helm RBAC cleanup Key: FLINK-35937 URL: https://issues.apache.org/jira/browse/FLINK-35937 Project: Flink Issue Type: Improvement Components: Kubernetes Oper

[DISCUSS] Remove deprecated dataset based API from State Processor API

2024-07-31 Thread Gabor Somogyi
Hi Devs, There is a common agreement that the dataset API going to be removed in 2.0. We're planning to invest quite some time in the State Processor API[1] in the near future. On this road we've realized that there are several deprecated APIs in this area which are based on the dataset API (for

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

2024-07-31 Thread Saurabh Singh
Hi Ahmed, Thank you very much for the detailed, valuable review. Please find our responses below: - In the FLIP you mention the split is going to be 1 sqs Queue, does this mean we would support reading from multiple queues? This is also not clear in the implementation of `addSplitsBack`

Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting

2024-07-31 Thread Timo Walther
+1 (binding) Thanks for fixing this critical bug. Regards, Timo On 31.07.24 09:51, Stefan Richter wrote: +1 (binding) Best, Stefan On 31. Jul 2024, at 04:56, Zakelly Lan wrote: +1 (binding) Best, Zakelly On Wed, Jul 31, 2024 at 12:07 AM Piotr Nowojski wrote: Hi all! I would like

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

2024-07-31 Thread Leonard Xu
+1 (binding) - checked Github release tag - verified signatures and hashsums - built from source code succeeded - reviewed the web PR, left minor comment - checked release notes, minor: there're some issues need to update Fix Version[1] - started SQL Client, used MySQL CDC connector to read chang

[jira] [Created] (FLINK-35938) Avoid commit the same datafile again in Paimon Sink.

2024-07-31 Thread LvYanquan (Jira)
LvYanquan created FLINK-35938: - Summary: Avoid commit the same datafile again in Paimon Sink. Key: FLINK-35938 URL: https://issues.apache.org/jira/browse/FLINK-35938 Project: Flink Issue Type: Te

[RESULT][VOTE] Release 1.20.0, release candidate #2

2024-07-31 Thread weijie guo
Hi everyone, I'm happy to announce that we have unanimously approved this release. There are 7 approving votes, 5 of which are binding: - Rui Fan(binding) - Ahmed Hamdy(non-binding) - Samrat Deb(non-binding) - Jing Ge(binding) - Xintong Song (binding) - Qingsheng Ren(binding) - Leonard

[jira] [Created] (FLINK-35939) Do not set empty config values via ConfigUtils#encodeCollectionToConfig

2024-07-31 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-35939: Summary: Do not set empty config values via ConfigUtils#encodeCollectionToConfig Key: FLINK-35939 URL: https://issues.apache.org/jira/browse/FLINK-35939 Project: Flin

Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting

2024-07-31 Thread Rui Fan
+1(binding) Best, Rui Timo Walther 于2024年7月31日 周三17:47写道: > +1 (binding) > > Thanks for fixing this critical bug. > > Regards, > Timo > > On 31.07.24 09:51, Stefan Richter wrote: > > > > +1 (binding) > > > > Best, > > Stefan > > > > > > > >> On 31. Jul 2024, at 04:56, Zakelly Lan wrote: > >> >

Re: [DISCUSS] Remove deprecated dataset based API from State Processor API

2024-07-31 Thread Gyula Fóra
Hi! Thanks Gabor for looking into this. +1 for removing the DataSet based APIs from the state processor in the next Flink version, I don't think we should wait until 2.0. This will also reduce the 2.0 scope overall which is always good :) Cheers, Gyula On Wed, Jul 31, 2024 at 10:30 AM Gabor Somo

[jira] [Created] (FLINK-35940) Upgrade log4j dependencies to 2.23.1

2024-07-31 Thread Daniel Burrell (Jira)
Daniel Burrell created FLINK-35940: -- Summary: Upgrade log4j dependencies to 2.23.1 Key: FLINK-35940 URL: https://issues.apache.org/jira/browse/FLINK-35940 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-35941) Add CompiledPlan annotations to BatchExecLimit

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35941: -- Summary: Add CompiledPlan annotations to BatchExecLimit Key: FLINK-35941 URL: https://issues.apache.org/jira/browse/FLINK-35941 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35942) Add CompiledPlan annotations to BatchExecSort

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35942: -- Summary: Add CompiledPlan annotations to BatchExecSort Key: FLINK-35942 URL: https://issues.apache.org/jira/browse/FLINK-35942 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-35943) Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35943: -- Summary: Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin Key: FLINK-35943 URL: https://issues.apache.org/jira/browse/FLINK-35943 Project: Fl

[jira] [Created] (FLINK-35944) Add CompiledPlan annotations to BatchExecUnion

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35944: -- Summary: Add CompiledPlan annotations to BatchExecUnion Key: FLINK-35944 URL: https://issues.apache.org/jira/browse/FLINK-35944 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35945) Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka

2024-07-31 Thread Jira
任铭睿 created FLINK-35945: --- Summary: Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka Key: FLINK-35945 URL: https://issues.apache.org/jira/browse/FLINK

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-31 Thread Xia Sun
Hi Lincoln, Thanks for your detailed explanation. I understand your concern. Introducing configuration with redundant semantics can indeed confuse users, and the engine should minimize user exposure to these details. Based on this premise, while also ensuring that users can choose to enable the br

[jira] [Created] (FLINK-35946) Finalize release 1.20.0

2024-07-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35946: -- Summary: Finalize release 1.20.0 Key: FLINK-35946 URL: https://issues.apache.org/jira/browse/FLINK-35946 Project: Flink Issue Type: New Feature Repor

[jira] [Created] (FLINK-35947) CLONE - Deploy Python artifacts to PyPI

2024-07-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35947: -- Summary: CLONE - Deploy Python artifacts to PyPI Key: FLINK-35947 URL: https://issues.apache.org/jira/browse/FLINK-35947 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35949) CLONE - Create Git tag and mark version as released in Jira

2024-07-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35949: -- Summary: CLONE - Create Git tag and mark version as released in Jira Key: FLINK-35949 URL: https://issues.apache.org/jira/browse/FLINK-35949 Project: Flink Issu

[jira] [Created] (FLINK-35948) CLONE - Deploy artifacts to Maven Central Repository

2024-07-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35948: -- Summary: CLONE - Deploy artifacts to Maven Central Repository Key: FLINK-35948 URL: https://issues.apache.org/jira/browse/FLINK-35948 Project: Flink Issue Type:

[jira] [Created] (FLINK-35950) CLONE - Publish the Dockerfiles for the new release

2024-07-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35950: -- Summary: CLONE - Publish the Dockerfiles for the new release Key: FLINK-35950 URL: https://issues.apache.org/jira/browse/FLINK-35950 Project: Flink Issue Type: S