Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

Hi Alex, thanks for creating the FLIP. One question: Is it intentionally done that the FLIP only covers the 1.x LTS version? Why don't we make the FLIP generic to also apply to other major version upgrades? Best, Matthias On Sat, May 25, 2024 at 4:55 PM Xintong Song wrote: > > > > I think our s

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

+1 (binding) Best, Jark On Mon, 27 May 2024 at 14:29, Hang Ruan wrote: > +1 (non-binding) > > Best, > Hang > > gongzhongqiang 于2024年5月27日周一 14:16写道： > > > +1 (non-binding) > > > > Best, > > Zhongqiang Gong > > > > Jane Chan 于2024年5月24日周五 09:52写道： > > > > > Hi all, > > > > > > I'd like to star

[jira] [Created] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

yuanfenghu created FLINK-35462: -- Summary: Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator. Key: FLINK-35462 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

hk__lrzy created FLINK-35463: Summary: CDC job failed when restored from checkpoint when route rule changed. Key: FLINK-35463 URL: https://issues.apache.org/jira/browse/FLINK-35463 Project: Flink

Re: [DISCUSS] The performance of serializerHeavyString starts regress since April 3

Thanks Sam for the comment! > It looks like the most recent run of JDK 11 saw a big improvement of the > performance of the test. I guess that improvement is a fluctuation. You can double check the performance results[1] of the last few days. The performance isn't recovered. > That improvement s

Re: [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - built from source code with JDK 11 succeed - checked release notes - reviewed the web PR Best, Hang Leonard Xu 于2024年5月22日周三 21:02写道： > > > +1 (binding) > > > > - verified signatures > > - verified hashsums > > - built from source co

Re: [VOTE] FLIP-443: Interruptible watermark processing

+1 (binding) > On 24. May 2024, at 09:59, Martijn Visser wrote: > > +1 (binding) > > On Fri, May 24, 2024 at 7:31 AM weijie guo > > wrote: > >> +1(binding) >> >> Thanks for driving this! >> >> Best regards, >> >> Weijie >> >> >> Rui Fan <1996fan...@gm

Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR - check the jar is built with JDK 1.8 Best, Hang Leonard Xu 于2024年5月22日周三 21:07写道： > +1 (binding) > > - verified signatures > - verified hash

Re: [DISCUSS] Flink CDC 3.2 Release Planning

+1 for the new schedule. I think it can reduce the work pressure of the committers, and it's also good for ensuring the code quality. On Mon, May 27, 2024 at 10:37 AM Xiqian YU wrote: > Hi devs, > > Glad to see Flink CDC 3.1’s successful release! Also noticed that it’s a > delayed release due to

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Hey Xiqian, +1 to the change of schedule Thanks and best, Muhammet On 2024-05-27 02:36, Xiqian YU wrote: Hi devs, Glad to see Flink CDC 3.1’s successful release! Also noticed that it’s a delayed release due to license compliance chores, which took more than half a month to process. In 3.2

Re: [DISCUSS] Flink 1.19.1 release

+1 for releasing 1.19.1 and Hong as RM. Thank you for volunteering! Best regards, Weijie Rui Fan <1996fan...@gmail.com> 于2024年5月27日周一 11:45写道： > +1 for release 1.19.1 and Hong as release manager. > > We are really looking forward to this version, thank you. > > Best, > Rui > > On Mon, May 27,

[jira] [Created] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

yux created FLINK-35464: --- Summary: Flink CDC 3.1 breaks operator state compatiblity Key: FLINK-35464 URL: https://issues.apache.org/jira/browse/FLINK-35464 Project: Flink Issue Type: Bug Comp

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Hey, Xiqian > In 3.2 KO plannings, it is expected to add some strongly demanded feature to > meet YAML pipeline job users’ needs [1]. However, 0 out of 10 3.2 feature > tickets have been completed till now, and it’s very unlikely for us to catch > up with planned feature freeze (May 25th) and r

[jira] [Created] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

Junrui Li created FLINK-35465: - Summary: Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures. Key: FLINK-35465 URL: https://issues.apache.org/jira/browse/FLINK-35465 Proje

[jira] [Created] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*`

Gyula Fora created FLINK-35466: -- Summary: Cannot pass all columns to SQL UDFs using `*` Key: FLINK-35466 URL: https://issues.apache.org/jira/browse/FLINK-35466 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environmen

Justin.Liu created FLINK-35467: -- Summary: The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environment variable. Key: FLIN

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

+1 (non-binding) Best regards, Xuannan On Mon, May 27, 2024 at 3:43 PM Jark Wu wrote: > > +1 (binding) > > Best, > Jark > > On Mon, 27 May 2024 at 14:29, Hang Ruan wrote: > > > +1 (non-binding) > > > > Best, > > Hang > > > > gongzhongqiang 于2024年5月27日周一 14:16写道： > > > > > +1 (non-binding) > >

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

Hi devs, I would like to propose adding a dedicated Flink CDC channel to the Apache Flink Slack workspace. Creating a channel focused on Flink CDC will help community members easily find previous discussions and target new discussions and questions to the correct place. Flink CDC is a sufficientl

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

Thanks Zhongqiang for the proposal, we need the Channel and I should have been created it but not yet, +1 from my side. Best, Leonard > 2024年5月28日 上午11:54，gongzhongqiang 写道： > > Hi devs, > > I would like to propose adding a dedicated Flink CDC channel to the Apache > Flink Slack workspace.

[jira] [Created] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment

zhou zhuohan created FLINK-35468: Summary: [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment Key: FLINK-35468 URL: https://issues.apache.org/jira/browse/FLINK-35468 Project: Fli

[jira] [Created] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase

RocMarshal created FLINK-35469: -- Summary: Unstable test case 'testProject' of JdbcDynamicTableSourceITCase Key: FLINK-35469 URL: https://issues.apache.org/jira/browse/FLINK-35469 Project: Flink

[jira] [Created] (FLINK-35470) Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing incompatibilities with Java 17

Rajat Pratap Singh created FLINK-35470: -- Summary: Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing incompatibilities with Java 17 Key: FLINK-35470 URL: https://issues.apache.org/jira/browse/FLINK-3547

[jira] [Created] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19

Rui Fan created FLINK-35471: --- Summary: Kubernetes operator bumps the flink version to 1.19 Key: FLINK-35471 URL: https://issues.apache.org/jira/browse/FLINK-35471 Project: Flink Issue Type: Improve