Re: Updating HBase connector

+1 to release hbase connector version for Flink 1.20 (LTS) Best, Leonard

Re: [DISCUSS] Planning Flink 2.2

Thanks Hang for kicking off this thread. +1 for the release manager candidate and proposed release circle. Best, Leonard > 2025 8月 1 10:07，Hang Ruan 写道： > > Hi everyone, > With the release announcement of Flink 2.1, it's a good time to kick off > discussion of the next release 2.2. > > - Rel

Re: [VOTE] FLIP-529: Connections in Flink SQL and TableAPI

+1 (binding) Best, Leonard > 2025 8月 1 07:38，Mayank Juneja 写道： > > +1 (non binding) > > *Mayank Juneja* > Product Manager | Data Streaming and AI > > > On Thu, Jul 31, 2025 at 1:51 PM Ryan van Huuksloot > wrote: > >> +1 (non-binding) >> >> Thanks! >> >> Ryan van Huuksloot >> Staff Engine

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

> I suggest we modify ObjectIdentifier and let it have either 3 or 1 part. Then > we can also remove the need for FunctionIdentifier which exists for exactly > this purpose. +1 from my side Best, Leonard

Re: [ANNOUNCE] Apache Flink 2.1.0 released

Nice！ Thanks Ron and all involved for the great work. Best, Leonard > 2025 7月 31 14:30，Ron Liu 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 2.1.0, which is the first release for the Apache Flink 2.1 series. > > > Apache Flink® is an open-source st

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

>>> I hope the BasicConnectionFactory can be a common one that can feed most >> common users case, otherwise encrypt all options is a good idea. >> I updated to `DefaultConnectionFactory` which handles most of the secret >> keys. >> >> Thanks, >> Hao >> &g

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

t;>>> Best, >>>>>> Austin >>>>>> >>>>>> On Thu, Jul 17, 2025 at 13:07 Ryan van Huuksloot >>>>>> wrote: >>>>>> >>>>>>> Hi Mayank, >>>>>>> >>>>>>&

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - checked release notes - ran SQL values test via SQL client in standalone cluster - checked compiled version 55.0 (Java SE 11) - reviewed the web PR, left two comments 'NEED' to fix Best, Leonard > On 2025 Jul

Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project

Hey Joao, Thanks for kicking off this thread, I have some comments as follows: > Currently, Flink CDC uses Debezium 1.9, which is the last version > compatible with Java 8. While an upgrade to Flink 2.0 will likely enable a > move to a newer version, we would still be constrained to Debezium 2.7

Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source

Thanks Zexian for driving this work. Rate limiting is a common requirement, TBH, we should have supported it in earlier stage, and the proposed design integrating it into the source operator lifecycle, it is already able to meet the vast majority of scenarios, looks good from my side. Best, L

Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment

Thanks Hongshun for driving this work. We also suffering the issue in production Kafka restoration usage, current design is a nice tradeoff and has considered the new Source implementation details, +1 from my side. Best, Leonard > 2025 7月 19 18:59，Hongshun Wang 写道： > > Hi devs, > > I'd

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

but I wanted to call >>>> this >>>>> out. >>>>> >>>>> table.catalog-store.kind: filetable.catalog-store.file.path: >>>>> file:///path/to/catalog/store/ >>>>> >>>>> Ryan van Huuksloot >>>>>

[jira] [Created] (FLINK-38059) [docs] Add fluss pipeline connector documentation

Leonard Xu created FLINK-38059: -- Summary: [docs] Add fluss pipeline connector documentation Key: FLINK-38059 URL: https://issues.apache.org/jira/browse/FLINK-38059 Project: Flink Issue Type

[jira] [Created] (FLINK-38058) Add e2e test for fluss pipeline connector

Leonard Xu created FLINK-38058: -- Summary: Add e2e test for fluss pipeline connector Key: FLINK-38058 URL: https://issues.apache.org/jira/browse/FLINK-38058 Project: Flink Issue Type: Sub-task

Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink

+1 for Robert’s point. Best, Leonard > 2025 7月 3 14:26，Robert Metzger 写道： > > a regular 3 > binding PMC vote is sufficient here:

Re: Flink CDC Pipeline connector support for Postgres

Hey Balu The feature will be supported in next release, contributor wulin has raised a PR[1], and we’re reviewing and improving it. Best, Leonard [1]https://github.com/apache/flink-cdc/pull/3968 > 2025 7月 3 06:00，dontu balu 写道： > > Hi team, > > > We have a requirement for Postgres CDC to Ic

[jira] [Created] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

Shuai Xu created FLINK-38032: Summary: Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode Key: FLINK-38032 URL: https://issues.apache.org/jira/browse/FLINK-38032 Project: Flink

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

em level > connections, we can support CREATE SYSTEM CONNECTION GlobalName WITH (..) > similar to SYSTEM functions directly store in a ConnectioManager in > TableEnvironment. But for now I would suggest to start simple with > per-catalog connections and later evolve the design. > >

Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

Looks like a bug, could you file an issue on jira like [1] ? Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-34874 > 2025 6月 24 11:50，Qiang He 写道： > > ``` > 2025-06-19 15:17:22,914 INFO > org.apache.flink.cdc.connectors.mysql.source.assigners.MySqlChunkSplitter > [] - The actual

Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink

+1(binding) Best, Leonard > 2025 6月 20 22:12，Mehdi Deboub 写道： > > +1 (non-binding) > > On 2025/06/06 16:09:03 David Radley wrote: >> Hi everyone, >> >> I'd like to start a vote on FLIP-532: Donate GetInData HTTP Connector to > Flink [1], which has been discussed in this thread [2]. The form

Re: Flink CDC and Debezium Version

Hey, Mohsen The highest supported Flink version is 1.20 in Flink CDC, and this Flink version uses JDK8 by default, but Debezium 2+ requires JDK11 at least, That’s why the Debezium version bump task is stale. IMO, once Flink CDC’s lowest supported Flink version becomes 2.0(which uses JDK11), it’s

[jira] [Created] (FLINK-37947) Add sql hint to enable this optimization

Shuai Xu created FLINK-37947: Summary: Add sql hint to enable this optimization Key: FLINK-37947 URL: https://issues.apache.org/jira/browse/FLINK-37947 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37921) Refactor current implementation with implementation in FLIP-425

Shuai Xu created FLINK-37921: Summary: Refactor current implementation with implementation in FLIP-425 Key: FLINK-37921 URL: https://issues.apache.org/jira/browse/FLINK-37921 Project: Flink

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

> have global ones as well. > > What do you think? > > Let me spend some more thoughts on this and come back with a concrete > proposal by early next week. > > Cheers, > Timo > > [1] https://docs.snowflake.com/en/sql-reference/sql/create-secret > [2] ht

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

, > Databricks does scopes it on a Unity catalog, Snowflake on a database > level). > > Also looking forward to Leonard's input. > > Best regards, > > Martijn > > [1] https://issues.apache.org/jira/browse/FLINK-36818 > [2] https://www.iso.org/standard/84804.html

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: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

+1 (non-binding) > On Jun 2, 2025, at 11:03, Mingge Deng wrote: > > +1 > > On Mon, Jun 2, 2025 at 7:53 AM Yuan Mei wrote: > >> +1 (binding) >> >> On Mon, Jun 2, 2025 at 5:07 PM Martijn Visser >> wrote: >> >>> +1 (binding) >>> >>> On Mon, Jun 2, 2025 at 9:07 AM Robert Metzger >> wrote: >>

[jira] [Created] (FLINK-37876) Introduce key ordered component in runtime

Shuai Xu created FLINK-37876: Summary: Introduce key ordered component in runtime Key: FLINK-37876 URL: https://issues.apache.org/jira/browse/FLINK-37876 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37874) FLIP-519: Introduce async lookup key ordered mode

Shuai Xu created FLINK-37874: Summary: FLIP-519: Introduce async lookup key ordered mode Key: FLINK-37874 URL: https://issues.apache.org/jira/browse/FLINK-37874 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37877) Add the key ordered operator in table runtime

Shuai Xu created FLINK-37877: Summary: Add the key ordered operator in table runtime Key: FLINK-37877 URL: https://issues.apache.org/jira/browse/FLINK-37877 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37875) Introduce the option and the support of planner

Shuai Xu created FLINK-37875: Summary: Introduce the option and the support of planner Key: FLINK-37875 URL: https://issues.apache.org/jira/browse/FLINK-37875 Project: Flink Issue Type: Sub-task

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

[RESULT][VOTE] FLIP-519: Introduce async lookup key ordered mode

voted. Best regards, Xu Shuai [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-519%3A++Introduce+async+lookup+key+ordered+mode [2] https://lists.apache.org/thread/q1rksclrjllpqjvkklfqgp5dx3j2t38w

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

[VOTE]FLIP-519: Introduce async lookup key ordered mode

Hi devs, Thank you for providing feedback on FLIP-519: Introduce async lookup key ordered mode[1]. I'd like to start a vote on this FLIP. Here is the discussion thread[2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. Best, Xu Shua

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: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode

Hi, devs, There haven’t been any further responses to this email over the past few days. I'd like to initiate a vote on the current proposal[1] in the next few days. If there are any concerns about this FLIP-519[1], I will gladly pause and make necessary adjustments. Best, Xu Shua

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

Hi Xuannan, Are we planning to support Variant shredding in the future or just basic variant encoding for Flink? Thanks, Aihua

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] FLIP-519: Introduce async lookup key ordered mode

27;table.exec.async-lookup.output-mode=ORDERD', the lookup join in key > ordered should be 'yes', not 'no'. > ORDERD is naturally guaranteed to be ordered, it just doesn't depend on the > current implementation of this proposal, which is a bit confusing here. &

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] FLIP-519: Introduce async lookup key ordered mode

may be either ordered or unordered. Best, Xu Shuai > 2025年4月17日 14:53，Xuyang 写道： > > Hi, Shuai. > > This is a valuable addition to the current AsyncLookupJoin, and I’m > > generally in favor of it. > > > > > I have one question. Why do we need to intr

Re: [ANNOUNCE] New Apache Flink Committer - Yanquan Lv

Congratulations, Yanquan! Best, Xu Shuai > 2025年4月17日 14:27，Xuyang 写道： > > Congratulations, Yanquan!

Re: [ANNOUNCE] New Apache Flink Committer - Xiqian Yu

Congratulations! Best, Xu Shuai > 2025年4月17日 13:54，Lincoln Lee 写道： > > Congratulations, Xiqian! > > > Best, > Lincoln Lee > > > Shengkai Fang 于2025年4月17日周四 11:51写道： > >> Congratulations! >> >> Best >> Shengkai >> &

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: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode

Hi all, This FLIP will primarily focus on the implementation within the table module. As for support in the DataStream API, it will be addressed in a separate FLIP. > 2025年4月8日 09:57，shuai xu 写道： > > Hi devs, > > I'd like to start a discussion on FLIP-519: Introd

Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode

his FLIP. Hope this helps >> all the similar operators to implement. >> >> [1] https://cwiki.apache.org/confluence/x/S4p3EQ >> >> >> Best, >> Zakelly >> >> On Tue, Apr 8, 2025 at 10:00 AM shuai xu wrote: >> >>> Hi devs, >>>

[jira] [Created] (FLINK-37640) Type timestamp_ltz is converted timestamp wrongly when scanreuse

Shuai Xu created FLINK-37640: Summary: Type timestamp_ltz is converted timestamp wrongly when scanreuse Key: FLINK-37640 URL: https://issues.apache.org/jira/browse/FLINK-37640 Project: Flink

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: >

[DISCUSS] FLIP-519: Introduce async lookup key ordered mode

avoid influencing existing jobs. please find more details in the FLIP wiki document[1]. Looking forward to your feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-519%3A++Introduce+async+lookup+key+ordered+mode [2] https://lists.apache.org/thread/wczzjhw8g0jcbs8lw2jhtrkw858cmx5n Bes

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

  1   2   3   4   5   6   7   8   9   10   >