Re: [VOTE] Release 2.1.0, release candidate #1

+1 (non-binding) Checklist: - verified tarball checksums & gpg signatures are valid - confirmed that artifacts were built with JDK 11.0.22 and Maven 3.8.6 - confirmed target bytecode version is 55.0 (JDK 11) - played Flink SQL client with code snippets - compiled from source code locally with JDK

Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off

+1, thanks for driving this release! Best Regards, Xiqian > 2025年5月27日 11:38，Yanquan Lv 写道： > > sorry for the title and update: > [Discuss] Flink CDC 3.5 Kick Off > > > Yanquan Lv 于2025年5月27日周二 11:36写道： > >> Hi devs, >> >> As FlinkCDC 3.4 was released recently, it's a good time to kick off

Re: Potential regression in Flink CDC 3.4.0 mysql

Hi Egor, Thanks for reporting this! There is some changes in MySQL binlog offset comparing logic in FLINK-37191[1]. The MySQL binlog filename comparison code (which isn’t null-safe) throwing an NPE has been there for a long time, but the execution flow might have changed and triggers this probl

Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #3

Thanks Kunni for preparing this release! +1 (non-binding) - verified tarball checksum and signatures are valid - confirmed jar files were built with JDK 1.8.0_392 and Apache Maven 3.8.6, bytecode version is 52.0 - ran simple data integration job with schema evolution - ran transform performance b

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

Thanks Yanquan for preparing this release! I’ve downloaded the flink-cdc-3.4.0-rc1 tarball, but seems it’s still labeled as 3.4-SNAPSHOT. Maybe we should recompile it with the latest release-3.4 branch? Best Regards, Xiqian > 2025年4月27日 17:33，Yanquan Lv 写道： > > Hi everyone, > > Please revie

Re: [VOTE] Release flink-connector-jdbc v4.0.0, release candidate #3

+1 (non-binding) Checklist: - verified that checksum and gig signatures are valid - confirmed jar codes were built with JDK 11.0.16.1 and Apache Maven 3.8.6, bytecode version is 55.0 - built source code successfully with JDK 11 and 17 - confirmed that test cases & compatibility tests all passed

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #3

+1 (non-binding) I’ve done the following checklist: - Tarball sha512 checksum and gig signatures are valid - Compiled source code & ran test cases successfully with JDK 11 and 17 - Confirmed jars wwere built with JDK 11.0.23 and Apache Maven 3.8.6, bytecode version is 55.0 (correct) - Tested cre

Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #2

+1 (non-binding) Checklist: - Tarball sha512 checksum and gig signatures are valid - Compiled code & ran unit test cases successfully with JDK 11 and 17 - Confirmed jars were built with JDK 11.0.23 and Apache Maven 3.8.6, bytecode version is 55.0 - Reviewed JIRA release note & flink-web PR Best

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

+1 (non-binding) Checklist: * Verified tarball signature and checksum * Compiled code from source with JDK 17 * Ran test cases locally, all passed * Reviewed license and third-party notice Best Regards, Xiqian > 2025年4月8日 17:35，Mate Czagany 写道： > > +1 (non-binding) > > - Verified signature

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

+1 (non-binding) Checklist: - Verified tarball checksum and signatures are valid - Confirmed jars were built with JDK 1.8.0_301 and Apache Maven 3.8.6, Bytecode version is 52.0 - Compiled codes successfully with JDK 8, 11, and 17 - Tested MySQL JDBC read / write SQL jobs manually with Flink 1.20

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

+1 (non-binding) I’ve done the following checklist: - Tarball checksum and GPG signatures are valid - Jar files were built with JDK 1.8.0_381 and Apache Maven 3.8.6, bytecode version is 52.0 - Compiled source cod & ran unit test cases locally with JDK 8, 11, and 17 - Reviewed release note and fl

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

Hi Arvid, I think what Kunni is mentioning is the compiled JDK version (JDK 17 here), not the targeted class file version (JDK 8 here). The target version could be lower than the JDK version used. Actual target version could be determined by executing `javap -verbose X.class | grep version`, w

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

+1 (non-binding) Checklist: - Verified tarball checksum & signatures are valid - Compiled source code locally with JDK 17 - Ran unit test cases locally and all passed - Confirmed dist jars are targeted to 52.0 (Java 8) - Reviewed release notes and flink-web PR Best Regards, Xiqian > 2025年4月9日 1

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

+1 (non-binding) Checklist: - Verified tarball checksum & signatures are valid - Compiled source code locally with JDK 17 - Verified test cases locally and all passed - Reviewed flink-web PR and release notes Best Regards, Xiqian > 2025年4月8日 22:08，Arvid Heise 写道： > > Hi everyone, > Please rev

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (non-binding) Best Regards, Xiqian 2025年3月17日 18:25，Piotr Nowojski 写道： +1 (binding) best, Piotrek pon., 17 mar 2025 o 11:06 Efrat Levitan napisał(a): Hi everyone, I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] which has been discussed in this thread [2]. The vot

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

+1 (non-binding) * verified that tarball signature and checksum matches * built from source locally with JDK 17 * confirmed that jar files are compiled with Java 11 and Maven 3.8.6 * ran a few DataStream & SQL end-to-end jobs Best Regards, Xiqian > 2025年3月13日 01:17，Ferenc Csaky 写道： > > +1 (non

Re: Flink CDC to Paimon

Hi Taher, Since we’re creating a DataStream-based pipeline job with SQL Server CDC, schema change events must be handled manually. A possible approach would be: 1) Enable schema change events with `.includeSchemaChanges(true)` option, so DDL events will be parsed and encoded in `SourceRecord`s.

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

+1 (non-binding) * verified that tarball checksum matches * reviewed the PR updating flink website * compiled source code and ran test suites locally with Java 11 / 17 * tested MongoDB source / sink SQL connector with Flink 1.20.0 locally Thanks for Jiabao’s great work! Best Regards, Xiqian > J

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

+1 (non-binding) Thanks for driving this major release, I’ve done the following check list: - Tarball checksum matches - Confirmed that released binary tarball has valid third-party OSS notice file - Compiled source code successfully with OpenJDK 8 / 11 - Reviewed release note at https://github.c

Re: Flink CDC 3.3 Kick Off Proposal

Hi Yanquan, Thanks for kicking off the next major release! I’d like to suggest adding the following ticket into CDC 3.3 planning list: * FLINK-36041: Eliminate Calcite dependency during runtime[1] [1] https://issues.apache.org/jira/browse/FLINK-36041 Regards, Xiqian De : Yanquan Lv Date

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

Thanks Qingsheng for preparing this RC! +1 (non-binding) * confirmed tarball checksum matches * confirmed binaries were compiled with JDK 1.8 * compiled from source and ran newly added test cases * created an end-to-end pipeline job and tested transform + schema evolution cases

Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0

keeping original schema compatibility. Could you please make an assessment about if this should be added into 3.2 blockers list? Regards, Xiqian [1] https://issues.apache.org/jira/browse/FLINK-36128 De : Xiqian YU Date : mardi, 20 août 2024 à 10:39 À : dev@flink.apache.org Objet : Re: [VOTE

Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0

Hi Qingsheng, Just noticed another blocking issue https://issues.apache.org/jira/browse/FLINK-36092 that combining transform and schema evolution might cause data fields mislocation or job crash. Could you please add this into blockers list? Regards, Xiqian De : Qingsheng Ren Date : lundi, 1

Re: [VOTE] FLIP-460: Display source/sink I/O metrics on Flink Web UI

+1 (non-binding) Regards, Xiqian De : Yanquan Lv Date : mercredi, 17 juillet 2024 à 10:35 À : dev@flink.apache.org Objet : Re: [VOTE] FLIP-460: Display source/sink I/O metrics on Flink Web UI +1 (non-binding) Glad to see a more user-friendly display page. Best, Yanquan Rui Fan <1996fan...@gm

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

Congratulations, Zhongqiang! Best Regards, Xiqian De : Samrat Deb Date : lundi, 17 juin 2024 à 11:24 À : dev@flink.apache.org Cc : gongzhongqi...@apache.org Objet : Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Congratulations Zhongqiang Gong ! Bests, Samrat On Mon, Jun 17, 202

Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan

Congratulations Hang! 🥳 Best Regards, Xiqian De : Jiabao Sun Date : lundi, 17 juin 2024 à 11:24 À : dev@flink.apache.org Objet : Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan Congrats Hang, well deserved! Best, Jiabao Leonard Xu 于2024年6月17日周一 11:19写道： > Hi everyone, > On behalf of t

Re: [VOTE] Apache Flink CDC Release 3.1.1, release candidate #0

Thanks Qingsheng for driving this release! +1 (non-binding) * Verified tarball checksum * Compiled CDC from source * Confirmed jars were compiled with JDK 8 * Ran savepoint migration test from CDC 3.0.x * Ran Pipeline E2e tests with Flink 1.18.1 / 1.19.0 Regards, Xiqian De

Re: [VOTE] Release 1.19.1, release candidate #1

+1 (non-binding) * Checked download links & release tags * Verified that package checksums matched * Compiled Flink from source code with JDK 8 / 11 * Ran E2e data integration test jobs on local cluster Regards, yux De : Rui Fan <1996fan...@gmail.com> Date : vendredi, 7 juin 202

[DISCUSS] Flink CDC 3.1.1 Release

Hi devs, I would like to make a proposal about creating a new Flink CDC 3.1 patch release (3.1.1). It’s been a week since the last CDC version 3.1.0 got released [1], and since then, 7 tickets have been closed, 4 of them are of high priority. Currently, there are 5 items open at the moment: 1 o

Re: [DISCUSS] Flink CDC 3.2 Release Planning

eter Huang Date : jeudi, 9 mai 2024 à 23:31 À : dev@flink.apache.org Objet : Re: [DISCUSS] Flink CDC 3.2 Release Planning Thanks Qingsheng for driving the release! +1. I also would like to provide some help on CDC 3.2. Best Regards Peter Huang On Thu, May 9, 2024 at 3:21 AM Xiqian YU wrote: >

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Thanks Qingsheng for driving the release! +1. Would love to provide my help on CDC 3.2. Regards, Xiqian De : Hang Ruan Date : jeudi, 9 mai 2024 à 17:50 À : dev@flink.apache.org Objet : Re: [DISCUSS] Flink CDC 3.2 Release Planning Thanks Qinsheng for driving. I would like to provide some helps

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

Hi Qingsheng, Thanks! +1 (non-binding) · Compiled & Ran unit tests successfully · Ran ASF Incompatible license check · Tested MySQL -> Doris / StarRocks E2e cases · Tested transform projection & filter feature Regards, Xiqian Yu On 2024/05/

[jira] [Created] (FLINK-35120) Add Doris Pipeline connector integration test cases

Xiqian YU created FLINK-35120: - Summary: Add Doris Pipeline connector integration test cases Key: FLINK-35120 URL: https://issues.apache.org/jira/browse/FLINK-35120 Project: Flink Issue Type

[jira] [Created] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector

Xiqian YU created FLINK-35102: - Summary: Incorret Type mapping for Flink CDC Doris connector Key: FLINK-35102 URL: https://issues.apache.org/jira/browse/FLINK-35102 Project: Flink Issue Type

[jira] [Created] (FLINK-35092) Add integrated test for Doris sink pipeline connector

Xiqian YU created FLINK-35092: - Summary: Add integrated test for Doris sink pipeline connector Key: FLINK-35092 URL: https://issues.apache.org/jira/browse/FLINK-35092 Project: Flink Issue Type

[jira] [Created] (FLINK-35090) Doris sink fails to create table when database does not exist

Xiqian YU created FLINK-35090: - Summary: Doris sink fails to create table when database does not exist Key: FLINK-35090 URL: https://issues.apache.org/jira/browse/FLINK-35090 Project: Flink

[jira] [Created] (FLINK-35079) MongoConnector failed to resume token when current collection removed

Xiqian YU created FLINK-35079: - Summary: MongoConnector failed to resume token when current collection removed Key: FLINK-35079 URL: https://issues.apache.org/jira/browse/FLINK-35079 Project: Flink

[jira] [Created] (FLINK-35077) Add package license check for Flink CDC modules.

Xiqian YU created FLINK-35077: - Summary: Add package license check for Flink CDC modules. Key: FLINK-35077 URL: https://issues.apache.org/jira/browse/FLINK-35077 Project: Flink Issue Type

[jira] [Created] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent

Xiqian YU created FLINK-35072: - Summary: Doris pipeline sink does not support applying AlterColumnTypeEvent Key: FLINK-35072 URL: https://issues.apache.org/jira/browse/FLINK-35072 Project: Flink

[jira] [Created] (FLINK-35055) Flink CDC connector release contains jar with incompatible licenses

Xiqian YU created FLINK-35055: - Summary: Flink CDC connector release contains jar with incompatible licenses Key: FLINK-35055 URL: https://issues.apache.org/jira/browse/FLINK-35055 Project: Flink