Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

+1 (binding) Best, Leonard > 2025 6月 3 11:51，Nishita Pattanayak 写道： > > +1 (non-binding) > Looking forward to this project ! > > Regards, > Nishita Pattanayak > > On Tue, 3 Jun 2025 at 08:32, Zakelly Lan wrote: > >> +1 (binding) >> >> Looking forward to the new project >> >> >> Best, >

Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support

+1 for the proposed plan and timeline, thanks Poorvank for driving this FLIP. Best, Leonard > 2025 6月 3 11:30，Poorvank Bhatia 写道： > > Hi all, > > I would like to start a discussion around moving the current Cassandra Sink > in Flink >

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

Hey Mayank. Thanks for the FLIP, I went through this FLIP quickly and found some issues which I think we need to deep discuss later. As we’re on a short Dragon boat Festival, could you kindly hold on this thread? and we will back to continue the FLIP discuss. Best, Leonard > 2025 4月 29 23

Re: Need invite link for the Flink community on Slack

Thanks Yanquan, would you like to open a PR to update our website link as well? Best, Leonard > 2025 5月 29 11:39，Yanquan Lv 写道： > > Hi, Siva. > > You can use this link[1] to join Flink community on Slack. > We will update the link on getting-help page later. > > [1] > https://apache-flink.sla

[DISCUSS] Flink CDC 3.5 Kick Off

Thanks Yanquan for volunteering to driving the Flink CDC 3.5 version. +1 for the plan, code freeze date and release manager candidate. Feel free to ping me if you need any help from PMC side. Best, Leonard > 2025 5月 27 11:36，Yanquan Lv 写道： > > Hi devs, > > As FlinkCDC 3.4 was released rece

Re: [ANNOUNCE] Apache Flink CDC 3.4.0 released

Thanks @Yanquan for the release management work and all involved! Best, Leonard > 2025 5月 16 22:40，Yanquan Lv 写道： > > The Apache Flink community is very happy to announce the release of > Apache Flink CDC 3.4.0. > > Apache Flink CDC is a distributed data integration tool for real time > data a

Re: [DISCUSS] Flink 1.19.3 release

+1, thanks Ferenc for driving this release. Best, Leonard > 2025 5月 9 15:56，Zakelly Lan 写道： > > +1 > > Thanks for volunteering > > > Best, > Zakelly > > On Fri, May 9, 2025 at 9:56 AM Ron Liu wrote: > >> +1 >> >> Best, >> Ron >> >> Gabor Somogyi 于2025年5月9日周五 00:06写道： >> >>> Thanks fo

Re: [DISCUSS] Flink 1.20.2 release

+1, thanks Ferenc for driving this release. Best, Leonard > 2025 5月 9 15:55，Zakelly Lan 写道： > > +1 > > Thanks for volunteering > > > Best, > Zakelly > > On Fri, May 9, 2025 at 3:42 PM Martijn Visser > wrote: > >> +1, thanks! >> >> On Fri, May 9, 2025 at 3:57 AM Ron Liu wrote: >> >>> +1

Re: [VOTE] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing

+1(binding) Best, Leonard > 2025 5月 8 09:58，Ron Liu 写道： > > +1(binding) > > Best, > Ron > > weijie guo 于2025年5月7日周三 21:15写道： > >> +1（binding) >> >> Best regards, >> >> Weijie >> >> >> Xintong Song 于2025年5月7日周三 19:37写道： >> >>> +1 (binding) >>> >>> Best, >>> >>> Xintong >>> >>> >>>

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with Java 8 succeeded - checked release notes - reviewed the web PR - checked the jar was built by JDK 8 version 52.0 (Java 1.8) Best, Leonard > 2025 4月 29 19:55，Yanquan Lv 写道： > > H

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

Thanks @Yanquan and @Xiqian for preparing the RC2. -1 as FLINK-37104 is a blocker issue, we should fix it before release. @Hongshun, FLINK-37738 is a feature request and which is created yesterday, I tend to postpone it to cdc 3.5 version. Best, Leonard > 2025 4月 28 16:04，Hongshun Wang 写道： >

Re: [DISCUSS] Release Flink CDC version 3.4.0

+1 to release 3.4.0 version, thanks Yanquan for driving the release work. Best, Leonard > 2025 4月 27 12:19，Yanquan Lv 写道： > > Hi everyone, > > Flink CDC v3.4.0 [1] has already updated Flink dependency to 1.20, added > Iceberg pipeline sink and introduced many important features like Batch >

Re: [ANNOUNCE] Apache flink-connector-jdbc 3.3.0 & 4.0.0 released

Nice work, Hang! Best, Leonard > 2025 4月 22 17:54，Hang Ruan 写道： > > The Apache Flink community is very happy to announce the release of > Apache flink-connector-jdbc 3.3.0 & 4.0.0. > > Apache Flink® is an open-source stream processing framework for > distributed, high-performing, always-availa

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

+1 (binding) - built from source code with Java 8 succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR - checked the failed test in RC2 has been fixed - checked the jar was built by JDK 8 version 52.0 (Java 1.8) Best, L

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

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR - checked the failed test in RC2 has been fixed - checked the jar was built by JDK 11 (Bytecode version is 55.0) Best, Leonard >

[jira] [Created] (FLINK-37706) [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space

Leonard Xu created FLINK-37706: -- Summary: [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space Key: FLINK-37706 URL: https://issues.apache.org

Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0

when you have time. > > Best, > Jiabao > > [1] https://repository.apache.org/content/repositories/orgapacheflink-1806/ > > Arvid Heise 于2025年3月28日周五 22:23写道： > >> I'd consider this an incomplete release that could just be fixed >> without any vot

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

+1 (binding) - checked the jar was built by JDK 11 (Bytecode version is 55.0) - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025 4月 15 11:57，Hang Ruan 写道： > > Hi everyone, > Please review and vote on rele

[ANNOUNCE] New Apache Flink Committer - Xiqian Yu

Hi everyone, On behalf of the PMC, I'm happy to let you know that Xiqian Yu has become a new Flink Committer! Since joining the Flink community in June 2023, Xiqian has become a core contributor and maintainer of the Flink CDC project, actively contributing to both code development and communi

[ANNOUNCE] New Apache Flink Committer - Yanquan Lv

Hi everyone, On behalf of the PMC, I'm happy to let you know that Yanquan Lv has become a new Flink Committer! Since joining the Flink community in September 2023, Yanquan has made significant contributions to the Flink CDC and Connector projects, establishing himself as a core contributor. He

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

+1 (binding) - verified signature - verified hashsum - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025 4月 10 17:52，Xiqian YU 写道： > > +1 (non-binding) > > Checklist: > > - Verified tarball checksum and signatures are valid > - Confirmed jars wer

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - checked release notes - checked compiled Java version is 52.0 (Java 1.8) - reviewed the web PR Best, Leonard > 2025 4月 14 09:57，Hongshun Wang 写道： > > +1 (non-binding) > > - verified JIRA release notes > -

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

-1 (binding) - Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is 52.0)， should be JDK 11 and supported by JDK17 as well Best, Leonard > 2025 4月 14 20:26，Leonard Xu 写道： > > -1 (binding) > > - Checked the jar was built incorrectly by JDK 1.8 (Bytecode ver

Re: [DISCUSS] Release new version of Flink JDBC Connector for Flink 2.0

Thanks Hang for driving this, +1 from my side. Best, Leonard

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - checked release notes - checked compiled Java version is 55.0 (Java SE 11) - reviewed the web PR Best, Leonard > 2025 4月 11 19:00，Xiqian YU 写道： > > +1 (non-binding) > > Checklist: > > - Tarball sha512 che

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

+1(binding) - verified signatures - verified hashsums - checked Github release tag - checked release notes - checked compiled Java version was 55.0 (Java SE 11) - reviewed the web PR, left two minor comments Best, Leonard > 2025 4月 12 19:59，Xiqian YU 写道： > > +1 (non-binding) > > I’ve done t

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

-1 (binding) - Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is 52.0)， should be JDK 17 - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025 4月 14 16:24，Hang Ruan 写道： > > Hi everyone, >

Re: [DISCUSS] Planning Flink 2.1

+1 for the final release manager, looking forward to Flink 2.1. Best, Leonard > 2025 4月 11 11:43，Ron Liu 写道： > > Hi everyone, > > The discussion has been ongoing for a long time, and there is currently 1 > RM candidate, so the final release manager of 2.1 is Ron Liu. We will do > the first rel

Re: [VOTE] FLIP-515: Dynamic Kafka Sink

Hi @Matyas, First of all, apologies for jumping into the vote thread. Could you kindly reply to Hongshun’s question in the discussion thread when you have a moment? Additionally, I have a question regarding the KafkaMetadataServiceImpl class mentioned in your proposed Public Interface. I revisi

Re: Kafka connector 4.0.0 release

+1, thanks @Arvid for driving this release! Best, Leonard > 2025 4月 7 18:02，Tom Cooper 写道： > > +1 from me. Thanks for driving this. > > Is there anything I can do to help? > > Tom Cooper > @tomcooper.dev | https://tomcooper.dev > > > On Monday, 7 April 2025 at 08:54, Arvid Heise wrote: >

Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan

Congratulation, Zakelly! Best, Leonard

Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector

+1（binding） Best, Leonard > 2025年3月27日 19:16，Roman Khachatryan 写道： > > +1 (binding) > > Regards, > Roman > > > On Thu, Mar 27, 2025 at 1:18 AM Efrat Levitan wrote: > >> +1 (non-binding) >> >> Thanks for addressing this issue! >> Efrat >> >> >> On Wed, 26 Mar 2025 at 17:35 Arvid Heise w

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Your link is broken, Shengkai Best, Leonard > 2025年3月27日 10:01，Shengkai Fang 写道： > > Hi, All. > > I write a simple demo to illustrate my idea. Hope this helps. > > Best, > Shengkai > > https://github.com/apache/flink/compare/master...fsk119:flink:example?expand=1 > > Gabor Somogyi 于2025年3

Re: [ANNOUNCE] Apache Flink 2.0.0 released

Congratulations! Thanks Xintong, Jark, Jiangjie and Martijn for the release management and all evolved. Best, Leonard > 2025年3月24日 16:24，Xintong Song 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 2.0.0, which is the first formal release for the

Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0

Thanks Jiabao for letting us know this issue, I think a new correct release would help users a lot. +1 from my side. From a process perspective, we are fixing the version number of an already released version, not the code in the corresponding version. I think a lightweight release vote should

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with JDK11 succeeded - tested using SQL Client to submit job and the query result is expected Best, Leonard > 2025年3月13日 19:17，Lincoln Lee 写道： > > +1 (binding) > > - verified signatur

[jira] [Created] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API

Leonard Xu created FLINK-37447: -- Summary: [Flink CDC] Supports Variant type in YAML API Key: FLINK-37447 URL: https://issues.apache.org/jira/browse/FLINK-37447 Project: Flink Issue Type: New

Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it

+1(binding) Best, Leonard > 2025年3月11日 18:42，Timo Walther 写道： > > +1 (binding) > > Thanks for working on this! > > Timo > > On 11.03.25 11:05, Dawid Wysakowicz wrote: >> Hi everyone, >> I'd like to start a vote on FLIP-510: Drop ChangelogNormalize for >> operations which don't need it[1] >>

[jira] [Created] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable

Leonard Xu created FLINK-37454: -- Summary: Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable Key: FLINK-37454 URL: https://issues.apache.org/jira/browse/FLINK-37454 Project: Flink

Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it

+1 for this proposal after went through Dawid and Xuyang’s discussion, and I think we can start a vote if there’re no objections. For the naming, shorter is better in this case, +1 for ChangelogMode.keyOnlyDeletes() after discussed with ChatGPT. Best, Leonard

[jira] [Created] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed

Leonard Xu created FLINK-37453: -- Summary: Migration Tests / data_stream_migration_test (8, 1.20.1) failed Key: FLINK-37453 URL: https://issues.apache.org/jira/browse/FLINK-37453 Project: Flink

Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API

tandardized enough. > > Thanks, > Yash Anand > > > > On Mon, Mar 10, 2025 at 11:08 PM Leonard Xu wrote: > >> Sorry for jumping the thread late, but I think current status of this FLIP >> is not ready, at least for me >> >> (1) Could you finish your propo

Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API

Sorry for jumping the thread late, but I think current status of this FLIP is not ready, at least for me (1) Could you finish your proposed API according Flink API bylaws? For example the code piece should be: Builder { SELF option(String key, String value SELF setComment(@Null

Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner

+1 (binding) Best, Leonard > 2025年2月25日 10:12，weijie guo 写道： > > +1(binding) > > Best regards, > > Weijie > > > Zhanghao Chen 于2025年2月23日周日 16:36写道： > >> +1 (non-binding) >> >> Thanks for driving this. It's a nice useability improvement for performing >> partial-updates on datalakes. >>

Re: Flink CDC to Paimon

Hey Taher, Xianqian has replied your email, did you subscribe Flink dev mailing-list? Best, Leonard > 2025年2月11日 16:52，Xiqian YU 写道： > > Hi Taher, > > Since we’re creating a DataStream-based pipeline job with SQL Server CDC, > schema change events must be handled manually. A possible approac

Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin

Congratulations, Feng. Best, Leonard > 2025年2月21日 14:02，Jacky Lau 写道： > > Congratulations! > > Best, > Jacky > > Xuyang 于2025年2月21日周五 11:57写道： > >> Congratulations, Feng Jin ;)-- >> >>Best！ >>Xuyang >> >> >> >> >> >> 在 2025-02-21 11:16:14，"Wei Zuo" <1015766...@qq.com.INVALID>

[jira] [Created] (FLINK-37362) PolardbxCharsetITCase test has timed out after 60 minutes

Leonard Xu created FLINK-37362: -- Summary: PolardbxCharsetITCase test has timed out after 60 minutes Key: FLINK-37362 URL: https://issues.apache.org/jira/browse/FLINK-37362 Project: Flink Issue

[jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift

Leonard Xu created FLINK-37306: -- Summary: Flink CDC CI failed due to timezone shift Key: FLINK-37306 URL: https://issues.apache.org/jira/browse/FLINK-37306 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue

Leonard Xu created FLINK-37305: -- Summary: JDBC Connector CI failed due to network issue Key: FLINK-37305 URL: https://issues.apache.org/jira/browse/FLINK-37305 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

Leonard Xu created FLINK-37304: -- Summary: Dynamic Kafka Source logs credentials in plaintext under INFO Key: FLINK-37304 URL: https://issues.apache.org/jira/browse/FLINK-37304 Project: Flink

Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1

pproved this release. > > There are XXX approving votes, XXX of which are binding: > * Maximilian Michels (binding) > * Marton Balassi (binding) > * Leonard Xu (binding) > * Robert Merzger (binding) > * Yanquan Lv (non-binding) > * Ferenc Csaky (non-binding) > *

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

+1 (binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025年2月7日 19:08，Rui Fan <1996fan...@gmail.com> 写道： > > +1 (binding) > > 1. Verified the archives,

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

+1 (binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025年2月11日 19:09，Márton Balassi 写道： > > +1 (binding) > > 1. Verified the archives, checksums, and

Re: Introduce TDengine connector

Hey, Kevinmen Welcome to Flink Community, Could you open public permission（view & comment） for the Google docs ? Best, Leonard > 2025年2月10日 12:51，门世斌 写道： > > Hi, there. > We have completed the writing of the Introduction TDengine connector > Google document. Please refer to the link be

Re: Request for PMC help with flink-connector-hive release

Hey, Sergey DONE via [1][2], please go on your release process. Best, Leonard [1] https://dist.apache.org/repos/dist/release/flink/flink-connector-hive-3.0.0/ [2] https://issues.apache.org/jira/projects/FLINK/versions/12352591 > 2025年2月10日 10:15，Leonard Xu 写道： > > I’ll help it ou

Re: Request for PMC help with flink-connector-hive release

I’ll help it out, thanks Sergey for the great work. Best, Leonard > 2025年2月10日 05:01，Sergey Nuyanzin 写道： > > Hi everyone, > > I'm in a process of finalizing flink-connector-hive release > the voting passed [1] and [2] > > I continue steps from [3] and faced that I don't have enough permission

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

+1 (binding) - built from source code succeeded with Maven 3.9.9 and Java 1.8 - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025年2月6日 09:48，Xiqian YU 写道： > > +1 (non-binding) > > * verified that tarball c

Re: Cancel flink-connector-mongodb v2.0.0 release candidate #1

Thanks Jiabao for driving this work, +1 to fix this ticket and start RC2 Best, Leonard > 2025年2月5日 16:19，Jiabao Sun 写道： > > Hi, > > During the release verification of flink-connector-mongodb v2.0.0, a > blocker[1] was found. > > This bug is related to the new config option scan.partition.reco

Re: [VOTE] Release flink-connector-hive, release candidate #2

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - reviewed the web PR and left minor comment Best, Leonard

Re: [Discuss] Flink CDC 3.4 Kick Off

+1 for the proposed code freeze date Best, Leonard > 2025年1月22日 15:41，ConradJam 写道： > > +1 > > Yanquan Lv 于2025年1月22日周三 15:35写道： > >> Hi devs, >> >> As FlinkCDC 3.3 was released recently, it's a good time to kick off the >> upcoming Flink CDC 3.4 release cycle. >> >> In past community disc

Re: [ANNOUNCE] Apache Flink CDC 3.3.0 released

Thanks Hang for the great work and all contributors who involved! Best, Leonard > 2025年1月21日 17:48，Hang Ruan 写道： > > The Apache Flink community is very happy to announce the release of > Apache Flink CDC 3.3.0. > > Apache Flink CDC is a distributed data integration tool for real time > data an

[jira] [Created] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes

Leonard Xu created FLINK-37191: -- Summary: MySQL 'Compile and test' stage timeout after 90 minutes Key: FLINK-37191 URL: https://issues.apache.org/jira/browse/FLINK-37191 Project: Flink

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR and left minor comments Best, Leonard > 2025年1月20日 10:18，Xiqian YU 写道： > > +1 (non-binding) > > Thanks for driving

Re: [DISCUSS] Release Flink CDC version 3.3.0

Thanks RuanHang for kicking off this discussion, cannot wait this happens, +1 from my side. Best， Leonard > 2025年1月17日 15:38，Hang Ruan 写道： > > Hi everyone, > > I want to kick off the discussion for Flink CDC release v3.3.0. > > Flink CDC v3.3.0 [1] contains more connectors, update Flink de

[jira] [Created] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

Leonard Xu created FLINK-37124: -- Summary: Simplify the print log in Flink CDC schema Coordinator Key: FLINK-37124 URL: https://issues.apache.org/jira/browse/FLINK-37124 Project: Flink Issue

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

Thanks Sergey for picking up this ticket, +1 from my side. Best, Leonard > 2025年1月14日 10:06，Jark Wu 写道： > > +1 for externalizing hive connector > > Best, > Jark > > On Tue, 14 Jan 2025 at 10:01, Lincoln Lee wrote: > >> Thanks Sergey for driving this important work! >> >> +1 for finishing t

[jira] [Created] (FLINK-37017) Supports complex DataTypes in Flink CDC

Leonard Xu created FLINK-37017: -- Summary: Supports complex DataTypes in Flink CDC Key: FLINK-37017 URL: https://issues.apache.org/jira/browse/FLINK-37017 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment

Minor: A separate email [RESULT][VOTE]FLIP-xxx is recommended. Best, Leonard > On Dec 17, 2024, at 3:54 PM, Sergey Nuyanzin wrote: > > There were 5 +1 votes, 4 of which are binding: > > - Jim Hughes (non-binding) > - Timo Walther (binding) > - Leonard Xu (binding)

Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment

Thanks Sergey for driving this FLIP, +1(binding) Best, Leonard > On Dec 13, 2024, at 6:48 PM, Timo Walther wrote: > > +1 (binding) > > Thanks, > Timo > > > On 13.12.24 01:37, Jim Hughes wrote: >> Hi Sergey, >> +1 (non-binding) >> Cheers, >> Jim >> On Thu, Dec 12, 2024 at 2:51 PM Sergey

Re: [Discuss] Hive connector bump to Flink 1.20

+1 from my side, thanks Yanquan for the effort. Best, Leonard > On Dec 13, 2024, at 12:20 PM, Yanquan Lv wrote: > > Hi, developers. > > I would like to start a discuss about Hive connector bump to Flink 1.20. > > Hive connector externalization was finished in January of this year (thanks >

Re: [DISCUSS] Release flink-connector-mongodb 2.0.0

; > > If the community agrees to create this release, I'm happy to > volunteer as the release manager, if another PMC (Leonard Xu?) is happy to > assist with the PMC-related release steps! > > Best, > Jiabao > > [1] https://www.mail-archive.com/dev@flink.apache.

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR Best, Leonard > On Nov 21, 2024, at 8:09 PM, Yanquan Lv wrote: > > +1 (non-binding) > I checked: > - Review JIRA r

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag, NOTE: the code branch v3.4 is missed and should be created before release - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR Best, Leonard > On Nov 15, 2024, at 1

Re: [DISCUSS] Release Flink CDC version 3.2.1

Thanks Ruan Hang for the discussion, +1 for the release and RM. Best, Leonard > 2024年11月20日 上午11:00，Hang Ruan 写道： > > Hi everyone, > > I want to kick off the discussion for Flink CDC release v3.2.1. > > Our latest release v3.2.0 was more than two months ago [1]. Since then > there are many re

Re: Dynamic Iceberg Sink

Thanks Peter and Max for kicking off this discussion, +1 for this proposal. Dynamic Sink is a key improvement for Iceberg Sink, and it can be well integrated with Flink CDC’s pipeline sink in the future as well. Best, Leonard > 2024年11月13日 下午7:57，Maximilian Michels 写道： > > Thanks for drivin

Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END)

Hey Dawid, >val sink = new TestingAppendSink >tEnv.sqlQuery(sql).toDataStream.addSink(sink) >env.execute() > } > > and you get the misleading results for timestamp_ltz: > > > a,2020-10-10T00:00,2020-10-10T00:00:05,2020-10-09T16:00:04.999Z,4,11.10,5.0,1.0,2,Hi|Comment#1 The reason

Re: [DISCUSS] Changing return type of window properties (WINDOW_START/END)

Thanks Dawid for bringing this ticket to dev mailing list and Timo’s kindly ping. Firstly the example result is a little strange for me too, the print window_time looks incorrect, Could you post your entire example especially your session time zone? Back to the window_start/end return type, bo

Re: Kafka connector releases

Thanks @Yanquan for track this thread, and thanks @Arvid for the information, it makes sense to me Qingsheng will drive the release of flink-2.0-preview of Flink Kafka connector, and I’d like assist it too. Best, Leonard > 2024年11月6日 下午6:58，Arvid Heise 写道： > > Hi Yanquan, > > the current s

Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li

Congratulations Junrui ! Best, Leonard > 2024年11月6日 下午8:52，Hong Liang 写道： > > Congratulations Junrui! > > Hong > > On Wed, Nov 6, 2024 at 12:36 PM Yanquan Lv wrote: > >> Congratulations, Junrui! >> >> Best, >> Yanquan >> >>> 2024年11月5日 19:59，Zhu Zhu 写道： >>> >>> Hi everyone, >>> >>> On

[jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error

Leonard Xu created FLINK-36656: -- Summary: Flink CDC treats MySQL Sharding table with boolean type conversion error Key: FLINK-36656 URL: https://issues.apache.org/jira/browse/FLINK-36656 Project: Flink

Re: [DISCUSS] Release HBase connector with partial JDK support

+1 for the release and release manager candidate Best, Leonard > 2024年10月31日 下午8:04，Yanquan Lv 写道： > > +1 for the release HBase connector 4.0 with 1.18 and 1.19 support. > >> 2024年10月29日 00:03，Ferenc Csaky 写道： >> >> Hi, >> >> Based on this discussion I would like to suggest to move on with

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

or flink version. >> Supporting too many Flink versions is a hard work. We could support two >> last minor flink version like the external connectors did[1]. >> >> Best, >> Hang >> >> [1] >> https://cwiki.apache.org/confluence/pages/viewpage.acti

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

+1 from my side, supporting two minor flink version(1.19.* & 1.120.*) makes sense to me. Best, Leonard > 2024年10月17日 下午1:58，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 > Sin

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

/staging/org/apache/flink/flink-connector-kafka/3.3.0-1.19/ >> [2] >> >> https://repository.apache.org/content/repositories/staging/org/apache/flink/flink-connector-kafka/3.3.0-1.20/ >> >> On Tue, Oct 15, 2024 at 8:21 AM Arvid Heise wrote: >> >>>

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

- verified signatures - verified hashsums - checked Github release tag - reviewed the web PR TODO: Quick question about the url before vote. https://repository.apache.org/content/repositories/staging/org/apache/flink/flink-connector-kafka/3.3.0-1.19.1 https://repository.apache.org/content/repos

Re: Kafka connector releases

Thanks Arvid for the volunteering! + 1 for all of the three releases and RM candidate.Qingsheng and I would like to help the 4.0.0-preview which follows the Flink 2.0 preview, please feel free to ping us if you need any help. Btw, for other external connectors which highest supported flink ve

Re: Flink CDC 3.3 Kick Off Proposal

Thanks Yanquan for kicking off this discussion, Generally +1 for the proposed feature-freeze date and release manager candidate from my side. I’d like to be one of the release managers and offer necessary help. Best, Leonard > 2024年9月11日 下午5:24，Xiqian YU 写道： > > Hi Yanquan, > > Thanks f

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with JDK 1.8 succeeded - checked release notes, all blockers in RC0 have been fixed - run a CDC YAML job that sync data from MySQL to Kafka, the result is expected - reviewed the web PR a

Re: [jira](FLINK-36127) Apply for a jira account and repair bug

Welcome Yuming to join the Flink Community！ Your Jira account has been created and I’ve assigned ticket FLINK-36127 to you. Best, Leonard > 2024年8月22日 下午8:14，Yu Chen 写道： > > Hi Yunming, > > Thanks for help to resolve the ticket FLINK-36127, and welcome to join flink > community. > > I notic

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

Welcome @kyzheng for joining Flink Community, I just processed jira account pending requests these days, hope your jira account have been created. I’m not sure the result because the jira account request doesn’t contains applier’s email address, feel free to ping me if your account still not rea

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

Thanks Yanquan for the verification and raise up the issues, I think we need cancel this RC, we’ll prepare the RC1 after fixed the two issues. CC：QingSheng Best, Leonard > 2024年8月19日 上午10:28，Yanquan Lv 写道： > > -1 as there are two problems of stable reproduction for main connectors. > Met a N

Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su

Congratulations! Xuannan Best, Leonard

Re: [ANNOUNCE] Flink CDC release-3.2 branch cut

Thanks Qingsheng, I’ve merged the PR after the CI green, feel free to prepare the release candidate. Best, Leonard > 2024年8月13日 下午2:31，Qingsheng Ren 写道： > > Thanks for letting me know, Leonard! Please go ahead and merge it. > > Best, > Qingsheng > > On Tue, Aug 13,

Re: [ANNOUNCE] Flink CDC release-3.2 branch cut

Thanks Qingsheng for the release management! I just found I missed a PR[1] that support data event metadata type, which was planned to merge to release-3.2 branch, the PR has been reviewed and approved. May I merge it to release-3.2 branch as well? Best, Leonard [1]https://github.com/apache/f

Re: [DISCUSS] Release flink-connector-mongodb 2.0.0

Thanks Jiabao for kicking off this thread, +1 for the proposal. Feel free to ping me if you need help from PMC member side. Best, Leonard > 2024年8月8日 下午5:04，Jiabao Sun 写道： > > Hi, > > I would like to propose to create a release for flink-connector-mongodb > 2.0.0. > > From the last release

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

+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

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

+1(binding) Best, Leonard > 2024年7月16日 下午3:15，Robert Metzger 写道： > > +1 (binding) > > Nice to see this fixed ;) > > > > On Tue, Jul 16, 2024 at 8:46 AM Yong Fang wrote: > >> +1 (binding) >> >> Best, >> FangYong >> >> >> On Tue, Jul 16, 2024 at 1:14 PM Zhanghao Chen >> wrote: >> >>> H

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

Thanks for zhanghao for kicking off the thread. > It is especially confusing for simple ETL jobs where there's a single > chained operator with 0 input rate and 0 output rate. This case have confused flink users for a long time, +1 for the FLIP. Best, Leonard

Re: [ANNOUNCE] Apache Flink 1.19.1 released

Congratulations! Thanks Hong for the release work and all involved! Best, Leonard > 2024年6月19日 上午4:20，Hong Liang 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.19.1, which is the first bugfix release for the Apache Flink 1.19 > series. > > Apache

Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released

Congratulations! Thanks Qingsheng for the release work and all contributors involved. Best, Leonard > 2024年6月18日 下午11:50，Qingsheng Ren 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink CDC 3.1.1. > > Apache Flink CDC is a distributed data integration

  1   2   3   4   5   6   7   8   >