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

2025-04-16 Thread Jiabao Sun
Thanks Leonard and Arvid, The new staging jars were deployed on nexus[1]. Please help check it 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 j

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

2025-04-16 Thread Zakelly Lan
Congratulations! Best, Zakelly On Wed, Apr 16, 2025 at 8:27 PM Jiabao Sun wrote: > Congrats Yanquan! > > Best, > Jiabao > > On 2025/04/16 07:23:42 Leonard Xu wrote: > > Hi everyone, > > > > On behalf of the PMC, I'm happy to let you know that Yanquan Lv has > become a new Flink Committer! > >

[jira] [Created] (FLINK-37690) Fix flaky Kudu test table datagen

2025-04-16 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-37690: Summary: Fix flaky Kudu test table datagen Key: FLINK-37690 URL: https://issues.apache.org/jira/browse/FLINK-37690 Project: Flink Issue Type: Technical Debt

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

2025-04-16 Thread Zakelly Lan
Congratulations! Best, Zakelly On Wed, Apr 16, 2025 at 8:27 PM Yanquan Lv wrote: > Congratulations! > > Best, > Yanquan > > Jiabao Sun 于2025年4月16日周三 20:25写道: > > > Congrats Xiqian! > > > > Best, > > Jiabao > > > > On 2025/04/16 07:25:19 Leonard Xu wrote: > > > Hi everyone, > > > > > > On beha

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

2025-04-16 Thread Xuyang
Congratulations, Yanquan! -- Best! Xuyang 在 2025-04-17 13:54:05,"Lincoln Lee" 写道: >Congratulations, Yanquan! > > >Best, >Lincoln Lee > > >Shengkai Fang 于2025年4月17日周四 11:52写道: > >> Congratulations! >> >> Best >> Shengkai >> >> Samrat Deb 于2025年4月17日周四 11:12写道: >> >> > congratulati

Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs

2025-04-16 Thread Timo Walther
Hi everyone, great to see that this discussion gains momentum. Let me answer your questions below: @Hao 1. SEARCH_KEY planner representation and options Yes, internally nothing in the planner should change. The PTFs are just syntactic sugar to rules and nodes that already exist. Regarding t

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

2025-04-16 Thread shuai xu
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 >> >> Hongshun Wang 于2025年4月17日周四 10:39写道: >> >>> Congratulations! >>> >

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

2025-04-16 Thread Xuyang
Congratulations, Xiqian! -- Best! Xuyang 在 2025-04-17 14:01:28,"shuai xu" 写道: >Congratulations! > >Best, >Xu Shuai > >> 2025年4月17日 13:54,Lincoln Lee 写道: >> >> Congratulations, Xiqian! >> >> >> Best, >> Lincoln Lee >> >> >> Shengkai Fang 于2025年4月17日周四 11:51写道: >> >>> Co

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

2025-04-16 Thread Shengkai Fang
Congratulations! Best Shengkai Hongshun Wang 于2025年4月17日周四 10:39写道: > Congratulations! > > Best > Hongshun > > > 2025年4月16日 15:25,Leonard Xu 写道: > > > > becoming > >

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

2025-04-16 Thread Shengkai Fang
Congratulations! Best Shengkai Samrat Deb 于2025年4月17日周四 11:12写道: > congratulations Yanquan Lv! > > bests, > Samrat > > On Thu, 17 Apr 2025 at 8:10 AM, Hongshun Wang > wrote: > > > Congrats Yanquan ! > > > > Best, > > Hongshun > > > > On Wed, Apr 16, 2025 at 9:04 PM gongzhongqiang < > gongzhong

[jira] [Created] (FLINK-37694) Update version to 4.1-SNAPSHOT for es main branch

2025-04-16 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37694: -- Summary: Update version to 4.1-SNAPSHOT for es main branch Key: FLINK-37694 URL: https://issues.apache.org/jira/browse/FLINK-37694 Project: Flink Issue Type: Imp

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

2025-04-16 Thread 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 introduce additional parameters to control KEY_ORDERED and ALLOW_UNORDERED? In other words, what scenarios require allowing users to perform co

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

2025-04-16 Thread Jiabao Sun
Thanks Leonard for the verification. The staging jars was released. Best, Jiabao On 2025/04/16 12:33:14 Leonard Xu wrote: > +1 for corrected artifacts version > > - checked the pom version is correct > - checked the compiled java version is java 8 > > Best, > Leonard > > > > 2025 4月 16 20:1

[jira] [Created] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector

2025-04-16 Thread Gunnar Morling (Jira)
Gunnar Morling created FLINK-37691: -- Summary: Can't consume changelog stream with upsert-kafka connector Key: FLINK-37691 URL: https://issues.apache.org/jira/browse/FLINK-37691 Project: Flink

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

2025-04-16 Thread gongzhongqiang
Congrats Yanquan Lv! Well deserved. Best, Zhongqiang Gong Leonard Xu 于2025年4月16日周三 15:24写道: > 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 > signific

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

2025-04-16 Thread gongzhongqiang
Congratulations! Well deserved. Best, Zhongqiang Gong Leonard Xu 于2025年4月16日周三 15:27写道: > 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 > contributo

[jira] [Created] (FLINK-37692) ForSt Avoid deleting directory when reuse restored directory

2025-04-16 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-37692: Summary: ForSt Avoid deleting directory when reuse restored directory Key: FLINK-37692 URL: https://issues.apache.org/jira/browse/FLINK-37692 Project: Flink

[jira] [Created] (FLINK-37687) Bump flink-connector-aws to 2.0

2025-04-16 Thread Keith Lee (Jira)
Keith Lee created FLINK-37687: - Summary: Bump flink-connector-aws to 2.0 Key: FLINK-37687 URL: https://issues.apache.org/jira/browse/FLINK-37687 Project: Flink Issue Type: Bug Component

[ANNOUNCE] New Apache Flink Committer - Yanquan Lv

2025-04-16 Thread Leonard Xu
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: [ANNOUNCE] New Apache Flink Committer - Xiqian Yu

2025-04-16 Thread Jiabao Sun
Congrats Xiqian! Best, Jiabao On 2025/04/16 07:25:19 Leonard Xu wrote: > 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 maintaine

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

2025-04-16 Thread Yanquan Lv
Congratulations! Best, Yanquan Jiabao Sun 于2025年4月16日周三 20:25写道: > Congrats Xiqian! > > Best, > Jiabao > > On 2025/04/16 07:25:19 Leonard Xu wrote: > > 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 t

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

2025-04-16 Thread Jiabao Sun
Congrats Yanquan! Best, Jiabao On 2025/04/16 07:23:42 Leonard Xu wrote: > 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

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

2025-04-16 Thread Leonard Xu
+1 for corrected artifacts version - checked the pom version is correct - checked the compiled java version is java 8 Best, Leonard > 2025 4月 16 20:16,Jiabao Sun 写道: > > Thanks Leonard and Arvid, > > The new staging jars were deployed on nexus[1]. > Please help check it when you have time.

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

2025-04-16 Thread Zakelly Lan
+1 (binding) I have verified: - Checksum and signature - There are no binaries in the source archive - Release tag and staging jars, manifest shows they are built by JDK 11.0.23 - Built from source - Release notes and web PR Best, Zakelly On Mon, Apr 14, 2025 at 9:02 PM Leonard Xu wrote

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

2025-04-16 Thread Arvid Heise
Hi Tom, thanks for catching that. I also released kafka-3.3 so that's odd. I released 3.3 and 3.4 within a couple of weeks. I know that Mac OS likes to create files that start with . like .DS_STORE which is used to capture thumbnails. I don't specifically know what has changed. In this case, it's

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

2025-04-16 Thread Hongshun Wang
Congrats Yanquan ! Best, Hongshun On Wed, Apr 16, 2025 at 9:04 PM gongzhongqiang wrote: > Congrats Yanquan Lv! Well deserved. > > Best, > Zhongqiang Gong > > Leonard Xu 于2025年4月16日周三 15:24写道: > > > Hi everyone, > > > > On behalf of the PMC, I'm happy to let you know that Yanquan Lv has > becom

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

2025-04-16 Thread Samrat Deb
congratulations Yanquan Lv! bests, Samrat On Thu, 17 Apr 2025 at 8:10 AM, Hongshun Wang wrote: > Congrats Yanquan ! > > Best, > Hongshun > > On Wed, Apr 16, 2025 at 9:04 PM gongzhongqiang > wrote: > > > Congrats Yanquan Lv! Well deserved. > > > > Best, > > Zhongqiang Gong > > > > Leonard Xu 于

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

2025-04-16 Thread Samrat Deb
Congrats Xiqian Bests, Samrat On Thu, 17 Apr 2025 at 8:09 AM, Hongshun Wang wrote: > Congratulations! > > Best > Hongshun > > > 2025年4月16日 15:25,Leonard Xu 写道: > > > > becoming > >

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

2025-04-16 Thread weijie guo
Hi everyone, I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: - Yanquan Lv (non-binding) - Xiqian Yu (non-binding) - Leonard Xu (binding) - Zakelly Lan (binding) - Weijie Guo (binding) There are no disapproving vo

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

2025-04-16 Thread Hongshun Wang
Congratulations! Best Hongshun > 2025年4月16日 15:25,Leonard Xu 写道: > > becoming

[jira] [Created] (FLINK-37693) ForSt fails to restore from reused checkpoint

2025-04-16 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-37693: Summary: ForSt fails to restore from reused checkpoint Key: FLINK-37693 URL: https://issues.apache.org/jira/browse/FLINK-37693 Project: Flink Issue Type: Bug

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

2025-04-16 Thread Lincoln Lee
Congratulations, Yanquan! Best, Lincoln Lee Shengkai Fang 于2025年4月17日周四 11:52写道: > Congratulations! > > Best > Shengkai > > Samrat Deb 于2025年4月17日周四 11:12写道: > > > congratulations Yanquan Lv! > > > > bests, > > Samrat > > > > On Thu, 17 Apr 2025 at 8:10 AM, Hongshun Wang > > wrote: > > > >

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

2025-04-16 Thread Lincoln Lee
Congratulations, Xiqian! Best, Lincoln Lee Shengkai Fang 于2025年4月17日周四 11:51写道: > Congratulations! > > Best > Shengkai > > Hongshun Wang 于2025年4月17日周四 10:39写道: > > > Congratulations! > > > > Best > > Hongshun > > > > > 2025年4月16日 15:25,Leonard Xu 写道: > > > > > > becoming > > > > >

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

2025-04-16 Thread weijie guo
+1(binding) from my self I have checked: - Checksum and signature - Built from source via jdk11 - Release tag - Release note Best regards, Weijie Zakelly Lan 于2025年4月16日周三 22:06写道: > +1 (binding) > > I have verified: > > - Checksum and signature > - There are no binaries in the source arc

[VOTE] FLIP-524: CloudWatch Metric Sink Connector

2025-04-16 Thread Daren Wong
Hi devs, Thank you everyone for the feedback on FLIP-524: CloudWatch Metric Sink Connector https://cwiki.apache.org/confluence/display/FLINK/FLIP-524:+CloudWatch+Metric+Sink+Connector. I would like to start a vote for it. The vote will be open for at least 72 hours unless there is an objection

Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector

2025-04-16 Thread Daren Wong
Hi devs, Thanks Hong for the help with moving the Draft into a FLIP. I have opened a Vote thread for the FLIP here https://lists.apache.org/thread/48rdzjbh8wvo8dr9q15vlsh1f5cojx4q. I will keep this discussion thread open and please feel free to continue leaving any feedback and questions here.

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

2025-04-16 Thread Leonard Xu
+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

[jira] [Created] (FLINK-37688) FLIP-534: Amazon CloudWatch Metric Sink Connector

2025-04-16 Thread Daren Wong (Jira)
Daren Wong created FLINK-37688: -- Summary: FLIP-534: Amazon CloudWatch Metric Sink Connector Key: FLINK-37688 URL: https://issues.apache.org/jira/browse/FLINK-37688 Project: Flink Issue Type: New

[ANNOUNCE] New Apache Flink Committer - Xiqian Yu

2025-04-16 Thread Leonard Xu
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

[jira] [Created] (FLINK-37686) ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions

2025-04-16 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-37686: Summary: ForSt consecutive failed checkpoint due to check deleted file status when enableFileDeletions Key: FLINK-37686 URL: https://issues.apache.org/jira/browse/FLINK-37686

[jira] [Created] (FLINK-37689) Improve the comments and variable names for TaskMailbox

2025-04-16 Thread Jiaan Geng (Jira)
Jiaan Geng created FLINK-37689: -- Summary: Improve the comments and variable names for TaskMailbox Key: FLINK-37689 URL: https://issues.apache.org/jira/browse/FLINK-37689 Project: Flink Issue Typ

[DISCUSS] FLIP-523 - Handle TLS Certificate Renewal

2025-04-16 Thread Nicolas Fraison
Hi All, I'd like to start a discussion to Handle TLS Certificate Renewal Please provide some feedback on this proposal: https://cwiki.apache.org/confluence/display/FLINK/FLIP-523%3A+Handle+TLS+Certificate+Renewal Regards, Nicolas Fraison

Re: [DISCUSS] Add generalized type information to SQL state connector

2025-04-16 Thread Zakelly Lan
Hi Gabor, Thanks for driving this. Well this is a nice addition, so +1 from my side. Best, Zakelly On Tue, Apr 15, 2025 at 9:06 AM Gabor Somogyi wrote: > Hi All, > > I'd like to start a discussion of FLIP-522: Add generalized type > information to SQL state connector [1]. > Feel free to add