Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-16 Thread ConradJam
I am currently working on the Iceberg CDC Pipeline Connector, and support for it would be ideal, as the Iceberg Flink Connector already supports SinkV2. There's no reason why we shouldn't support it as well. So I'm +1 Yanquan Lv 于2024年10月17日周四 09:55写道: > Dear Flink devs, I would like to initiate

Re: [VOTE] FLIP-478: Introduce Config Option Scope

2024-10-16 Thread Zhu Zhu
+1 (binding) Thanks, Zhu Shengkai Fang 于2024年10月17日周四 10:09写道: > +1(binding) > > Best, > Shengkai > > Rui Fan <1996fan...@gmail.com> 于2024年10月17日周四 10:01写道: > > > +1(binding) > > > > Best, > > Rui > > > > On Thu, Oct 17, 2024 at 10:00 AM Junrui Lee wrote: > > > > > Hi devs, > > > > > > I'd lik

Re: [VOTE] Release 2.0-preview1, release candidate #1

2024-10-16 Thread Jingsong Li
+1 (binding) - Downloaded artifacts from dist - Verified SHA512 checksum - Verified GPG signature - Build the source with java-11 Best, Jingsong On Thu, Oct 17, 2024 at 11:53 AM Yunfeng Zhou wrote: > > +1 (non-binding) > > - Verified checksums > - Built from source > - Reviewed release notes >

Re: [VOTE] Release 2.0-preview1, release candidate #1

2024-10-16 Thread Yanquan Lv
+1 (non-binding) I checked: - Review JIRA release notes - Verify hashes and verify signatures - Build success from source with JDK11 & maven3.8.6 - Source code artifacts matching the current release - Read the announcement blog and LGTM - Run a sql job using File connector in a standalone cluster

Re: [VOTE] Release 2.0-preview1, release candidate #1

2024-10-16 Thread Yunfeng Zhou
+1 (non-binding) - Verified checksums - Built from source - Reviewed release notes - Ran WordCount example and it works as expected Best, Yunfeng > 2024年10月13日 00:46,Xintong Song 写道: > > Hi everyone, > > Please review and vote on the release candidate #1 for the version > 2.0-preview1, as fo

Re: [VOTE] FLIP-478: Introduce Config Option Scope

2024-10-16 Thread Shengkai Fang
+1(binding) Best, Shengkai Rui Fan <1996fan...@gmail.com> 于2024年10月17日周四 10:01写道: > +1(binding) > > Best, > Rui > > On Thu, Oct 17, 2024 at 10:00 AM Junrui Lee wrote: > > > Hi devs, > > > > I'd like to start a vote on the FLIP-478: Introduce Config Option > Scope[1]. > > The discussion thread i

Re: [VOTE] FLIP-478: Introduce Config Option Scope

2024-10-16 Thread Rui Fan
+1(binding) Best, Rui On Thu, Oct 17, 2024 at 10:00 AM Junrui Lee wrote: > Hi devs, > > I'd like to start a vote on the FLIP-478: Introduce Config Option Scope[1]. > The discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an objection or > insufficient

[VOTE] FLIP-478: Introduce Config Option Scope

2024-10-16 Thread Junrui Lee
Hi devs, I'd like to start a vote on the FLIP-478: Introduce Config Option Scope[1]. The discussion thread is here [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-478+Introduce+Config+

[DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-16 Thread Yanquan Lv
Dear Flink devs, I would like to initiate a discussion about upgrading the bump version of FlinkCDC to Flink 1.19. FlinkCDC's version was bumped to Flink 1.18 in November 2023[1], Almost a year has passed, during which Flink released two major versions, 1.19/1.20, and 1.20 is a LTS version. Th

Re: [VOTE] Release 2.0-preview1, release candidate #1

2024-10-16 Thread Rui Fan
+1 (binding) - Downloaded artifacts from dist - Verified SHA512 checksum - Verified GPG signature - Build the source with java-11 - Verified the license header during build the source - Run an example job, and it works as expected - Reviewed web PR and release note Best, Rui On Wed, Oct 16, 2024

[DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-16 Thread Yanquan Lv

[jira] [Created] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18

2024-10-16 Thread yux (Jira)
yux created FLINK-36558: --- Summary: MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 Key: FLINK-36558 URL: https://issues.apache.org/jira/browse/FLINK-36558 Project: Flink

[jira] [Created] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator

2024-10-16 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36557: - Summary: Stale Autoscaler Context in Kubernetes Operator Key: FLINK-36557 URL: https://issues.apache.org/jira/browse/FLINK-36557 Project: Flink Iss

Re: [VOTE] Release 2.0-preview1, release candidate #1

2024-10-16 Thread Yuan Mei
+1 - Verify checksum - Review release note Thank Xintong for driving the release and the great efforts put into making 2.0 successful! Best Yuan On Wed, Oct 16, 2024 at 2:49 PM Zhu Zhu wrote: > +1 (binding) > > - Verified checksums and release tag > - Built from source > - Run an example job

[jira] [Created] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36556: -- Summary: Allow to configure starting buffer size when using buffer debloating Key: FLINK-36556 URL: https://issues.apache.org/jira/browse/FLINK-36556 Project: Fli

[jira] [Created] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha

2024-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36555: -- Summary: Guarantee debloated buffer size grows even with very small alpha Key: FLINK-36555 URL: https://issues.apache.org/jira/browse/FLINK-36555 Project: Flink

[jira] [Created] (FLINK-36554) Support MapState in Operator State

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
Jacob Jona Fahlenkamp created FLINK-36554: - Summary: Support MapState in Operator State Key: FLINK-36554 URL: https://issues.apache.org/jira/browse/FLINK-36554 Project: Flink Issue Ty

[jira] [Created] (FLINK-36553) Local Global aggregation in Datasream API

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
Jacob Jona Fahlenkamp created FLINK-36553: - Summary: Local Global aggregation in Datasream API Key: FLINK-36553 URL: https://issues.apache.org/jira/browse/FLINK-36553 Project: Flink I

[jira] [Created] (FLINK-36552) Fix Table API OVER window support in batch mode

2024-10-16 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-36552: Summary: Fix Table API OVER window support in batch mode Key: FLINK-36552 URL: https://issues.apache.org/jira/browse/FLINK-36552 Project: Flink Issue

[jira] [Created] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore"

2024-10-16 Thread Keith Wall (Jira)
Keith Wall created FLINK-36551: -- Summary: Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore" Key: FLINK-36551 URL: https://issues.apache.org/jira/browse/FLINK-36551

[RESULT][VOTE] flink-connector-kafka 3.3.0, release candidate #1

2024-10-16 Thread Arvid Heise
I'm happy to announce that we have unanimously approved this release. There are 3 approving votes, 3 of which are binding: * Matthias Pohl (binding) * Rui Fan (binding) * Leonard Xu (binding) We also had approving votes for the version with incorrect snapshot names: * Yanquan Lv * Ahmed Hamdy * D

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

2024-10-16 Thread Arvid Heise
Thank you everyone for responding. I will close the vote now and announce the results. On Wed, Oct 16, 2024 at 4:17 AM Leonard Xu wrote: > Thanks Arvid for the quick update, +1 (binding) > > - verified signatures > - verified hashsums > - checked Github release tag > - checked release notes > -

Re: [DISCUSS] FLIP-478: Introduce Config Option Scope

2024-10-16 Thread Junrui Lee
Hi, devs After discussing offline with Lincoln Lee and Shengkai Fang, we realized that some SQL config options, like table.sql-dialect, may also server DDL in which case no Flink job will run. Including these options under the JOB scope is not accurate. So we propose introducing a new SQL_EXECUTI

[jira] [Created] (FLINK-36550) Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader

2024-10-16 Thread Jira
原来你是小幸运001 created FLINK-36550: -- Summary: Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader Key: FLINK-36550 URL: https://issues.apache.org/