Re: [DISCUSS] FLIP-408: [Umbrella] Introduce DataStream API V2

2024-02-19 Thread weijie guo
Hi All, Thanks for all the feedback. If there are no more comments, I would like to start the vote thread, thanks again! Best regards, Weijie Xintong Song 于2024年1月30日周二 11:04写道: > Thanks for working on this, Weijie. > > The design flaws of the current DataStream API (i.e., V1) have been a

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

2024-02-19 Thread weijie guo
Hi All, Thanks for all the feedback. If there are no more comments, I would like to start the vote thread, thanks again! Best regards, Weijie Xintong Song 于2024年2月20日周二 14:17写道: > Thanks for the updates. LGTM. > > Best, > > Xintong > > > > On Mon, Feb 19, 2024 at 10:51 AM weijie guo >

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-02-19 Thread weijie guo
Hi All, Thanks for all the feedback. If there are no more comments, I would like to start the vote thread, thanks again! Best regards, Weijie Xintong Song 于2024年2月20日周二 14:17写道: > LGTM > > Best, > > Xintong > > > > On Mon, Feb 19, 2024 at 10:48 AM weijie guo > wrote: > > > Hi All, > > > >

Re: [VOTE] Release flink-connector-parent 1.1.0 release candidate #2

2024-02-19 Thread Leonard Xu
+1 (binding) - verified signatures - verified hashsums - built from source code succeeded - checked Github release tag - checked release notes - reviewed all Jira tickets have been resolved - reviewed the web PR Best, Leonard > 2024年2月20日 上午11:14,Rui Fan <1996fan...@gmail.com> 写道: > > Thanks

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Runkang He
Congratulations Jiabao! Best, Runkang He Jane Chan 于2024年2月20日周二 14:18写道: > Congrats, Jiabao! > > Best, > Jane > > On Tue, Feb 20, 2024 at 10:32 AM Paul Lam wrote: > > > Congrats, Jiabao! > > > > Best, > > Paul Lam > > > > > 2024年2月20日 10:29,Zakelly Lan 写道: > > > > > >> Congrats! Jiabao! > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Jane Chan
Congrats, Jiabao! Best, Jane On Tue, Feb 20, 2024 at 10:32 AM Paul Lam wrote: > Congrats, Jiabao! > > Best, > Paul Lam > > > 2024年2月20日 10:29,Zakelly Lan 写道: > > > >> Congrats! Jiabao! > >

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-02-19 Thread Xintong Song
LGTM Best, Xintong On Mon, Feb 19, 2024 at 10:48 AM weijie guo wrote: > Hi All, > > Based on the discussion thread of FLIP-409, I did a synchronized update to > this one. In simple terms, added `TwoInputBroadcastStreamProcessFunction` > related content. > > > Best regards, > > Weijie > > >

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

2024-02-19 Thread Xintong Song
Thanks for the updates. LGTM. Best, Xintong On Mon, Feb 19, 2024 at 10:51 AM weijie guo wrote: > Thanks for the reply, Xintong. > > Based on your comments, I made the following changes to this FLIP: > > 1. Renaming `TwoInputStreamProcessFunction` and >

Re: Making CollectSinkFunction to wait till all results are consumed

2024-02-19 Thread Alexey Leonov-Vendrovskiy
Hey, Piotrek, Thanks for the response and thoughts! I don't think it is possible to tell the difference between different cases -- when someone would not want the results back from the instantiated CollectSinkFunction. It is not clear why this would be the case, unless it is some test flow that

Re: [VOTE] Release flink-connector-parent 1.1.0 release candidate #2

2024-02-19 Thread Rui Fan
Thanks for driving this, Etienne! +1 (non-binding) - Verified checksum and signature - Verified pom content - Build source on my Mac with jdk8 - Verified no binaries in source - Checked staging repo on Maven central - Checked source code tag - Reviewed web PR Best, Rui On Tue, Feb 20, 2024 at

Re: [VOTE] Release flink-connector-parent 1.1.0 release candidate #2

2024-02-19 Thread Qingsheng Ren
Thanks for driving this, Etienne! +1 (binding) - Checked release note - Verified checksum and signature - Verified pom content - Verified no binaries in source - Checked staging repo on Maven central - Checked source code tag - Reviewed web PR - Built Kafka connector from source with parent pom

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Paul Lam
Congrats, Jiabao! Best, Paul Lam > 2024年2月20日 10:29,Zakelly Lan 写道: > >> Congrats! Jiabao!

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Zakelly Lan
Congratulations, Jiabao! Best, Zakelly On Mon, Feb 19, 2024 at 9:40 PM Jing Ge wrote: > Congrats! Jiabao! > > Best regards, > Jing > > On Mon, Feb 19, 2024 at 2:38 PM Jeyhun Karimov > wrote: > > > Congratulations, Jiabao! > > Well deserved! > > > > On Mon, Feb 19, 2024 at 2:26 PM

[VOTE] Release flink-connector-parent 1.1.0 release candidate #2

2024-02-19 Thread Etienne Chauchot
Hi everyone, Please review and vote on the release candidate #2 for the version 1.1.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

[ANNOUNCE] Apache flink-connector-mongodb 1.1.0 released

2024-02-19 Thread Leonard Xu
The Apache Flink community is very happy to announce the release of Apache flink-connector-mongodb 1.1.0. This release is compatible with Flink 1.17.x and 1.18.x series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate

[jira] [Created] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

2024-02-19 Thread dongwoo.kim (Jira)
dongwoo.kim created FLINK-34470: --- Summary: Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging Key: FLINK-34470 URL:

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Jing Ge
Congrats! Jiabao! Best regards, Jing On Mon, Feb 19, 2024 at 2:38 PM Jeyhun Karimov wrote: > Congratulations, Jiabao! > Well deserved! > > On Mon, Feb 19, 2024 at 2:26 PM gongzhongqiang > wrote: > > > Congratulations, Jiabao! > > > > Best, > > Zhongqiang Gong > > > > Qingsheng Ren

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Jeyhun Karimov
Congratulations, Jiabao! Well deserved! On Mon, Feb 19, 2024 at 2:26 PM gongzhongqiang wrote: > Congratulations, Jiabao! > > Best, > Zhongqiang Gong > > Qingsheng Ren 于2024年2月19日周一 17:53写道: > > > Hi everyone, > > > > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread gongzhongqiang
Congratulations, Jiabao! Best, Zhongqiang Gong Qingsheng Ren 于2024年2月19日周一 17:53写道: > Hi everyone, > > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink > Committer. > > Jiabao began contributing in August 2022 and has contributed 60+ commits > for Flink main repo and

[jira] [Created] (FLINK-34469) Implement TableDistribution toString

2024-02-19 Thread Timo Walther (Jira)
Timo Walther created FLINK-34469: Summary: Implement TableDistribution toString Key: FLINK-34469 URL: https://issues.apache.org/jira/browse/FLINK-34469 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Jiabao Sun
Thanks, everyone! It is great to be part of such an active and collaborative community! On 2024/02/19 11:37:28 Feng Jin wrote: > Congratulations, Jiabao! > > > Best, > Feng > > On Mon, Feb 19, 2024 at 7:35 PM Sergey Nuyanzin wrote: > > > Congratulations, Jiabao! > > > > On Mon, Feb 19, 2024

Re: FW: RE: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

2024-02-19 Thread Martijn Visser
I'm a bit confused: did we add new interfaces after FLIP-314 was accepted? If so, please move the new interfaces to a new FLIP and start a separate vote. We can't retrospectively change an accepted FLIP with new interfaces and a new vote. On Mon, Feb 19, 2024 at 3:22 AM Yong Fang wrote: > > Hi

[jira] [Created] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34468: - Summary: Implement Lineage Interface in Cassandra Connector Key: FLINK-34468 URL: https://issues.apache.org/jira/browse/FLINK-34468 Project: Flink Issue

[jira] [Created] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34467: - Summary: Implement Lineage Interface in Jdbc Connector Key: FLINK-34467 URL: https://issues.apache.org/jira/browse/FLINK-34467 Project: Flink Issue Type:

[jira] [Created] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34466: - Summary: Implement Lineage Interface in Kafka Connector Key: FLINK-34466 URL: https://issues.apache.org/jira/browse/FLINK-34466 Project: Flink Issue Type:

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Feng Jin
Congratulations, Jiabao! Best, Feng On Mon, Feb 19, 2024 at 7:35 PM Sergey Nuyanzin wrote: > Congratulations, Jiabao! > > On Mon, Feb 19, 2024 at 12:26 PM Yanquan Lv wrote: > > > Congratulations, Jiabao. > > > > He Wang 于2024年2月19日周一 19:21写道: > > > > > Congrats, Jiabao! > > > > > > On Mon,

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Sergey Nuyanzin
Congratulations, Jiabao! On Mon, Feb 19, 2024 at 12:26 PM Yanquan Lv wrote: > Congratulations, Jiabao. > > He Wang 于2024年2月19日周一 19:21写道: > > > Congrats, Jiabao! > > > > On Mon, Feb 19, 2024 at 7:19 PM Benchao Li wrote: > > > > > Congrats, Jiabao! > > > > > > Zhanghao Chen 于2024年2月19日周一

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Yanquan Lv
Congratulations, Jiabao. He Wang 于2024年2月19日周一 19:21写道: > Congrats, Jiabao! > > On Mon, Feb 19, 2024 at 7:19 PM Benchao Li wrote: > > > Congrats, Jiabao! > > > > Zhanghao Chen 于2024年2月19日周一 18:42写道: > > > > > > Congrats, Jiaba! > > > > > > Best, > > > Zhanghao Chen > > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Matthias Pohl
Congratulations, Jiabao! On Mon, Feb 19, 2024 at 12:21 PM He Wang wrote: > Congrats, Jiabao! > > On Mon, Feb 19, 2024 at 7:19 PM Benchao Li wrote: > > > Congrats, Jiabao! > > > > Zhanghao Chen 于2024年2月19日周一 18:42写道: > > > > > > Congrats, Jiaba! > > > > > > Best, > > > Zhanghao Chen > > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread He Wang
Congrats, Jiabao! On Mon, Feb 19, 2024 at 7:19 PM Benchao Li wrote: > Congrats, Jiabao! > > Zhanghao Chen 于2024年2月19日周一 18:42写道: > > > > Congrats, Jiaba! > > > > Best, > > Zhanghao Chen > > > > From: Qingsheng Ren > > Sent: Monday, February 19, 2024 17:53 > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Benchao Li
Congrats, Jiabao! Zhanghao Chen 于2024年2月19日周一 18:42写道: > > Congrats, Jiaba! > > Best, > Zhanghao Chen > > From: Qingsheng Ren > Sent: Monday, February 19, 2024 17:53 > To: dev ; jiabao...@apache.org > Subject: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Zhanghao Chen
Congrats, Jiaba! Best, Zhanghao Chen From: Qingsheng Ren Sent: Monday, February 19, 2024 17:53 To: dev ; jiabao...@apache.org Subject: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun Hi everyone, On behalf of the PMC, I'm happy to announce Jiabao Sun as a

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Lincoln Lee
Congratulations Jiabao! Best, Lincoln Lee Leonard Xu 于2024年2月19日周一 18:25写道: > Congratulations, Jiabao! Well deserved. > > > Best, > Leonard > > > > 2024年2月19日 下午6:21,David Radley 写道: > > > > Congratulations Jiabao! > > > > From: Swapnal Varma > > Date: Monday, 19 February 2024 at 10:14 > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Leonard Xu
Congratulations, Jiabao! Well deserved. Best, Leonard > 2024年2月19日 下午6:21,David Radley 写道: > > Congratulations Jiabao! > > From: Swapnal Varma > Date: Monday, 19 February 2024 at 10:14 > To: dev@flink.apache.org > Subject: [EXTERNAL] Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

RE: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread David Radley
Congratulations Jiabao! From: Swapnal Varma Date: Monday, 19 February 2024 at 10:14 To: dev@flink.apache.org Subject: [EXTERNAL] Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun Congratulations Jiabao! Best, Swapnal On Mon, 19 Feb 2024, 15:37 weijie guo, wrote: > Congratulations,

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Swapnal Varma
Congratulations Jiabao! Best, Swapnal On Mon, 19 Feb 2024, 15:37 weijie guo, wrote: > Congratulations, Jiabao :) > > Best regards, > > Weijie > > > Hang Ruan 于2024年2月19日周一 18:04写道: > > > Congratulations, Jiabao! > > > > Best, > > Hang > > > > Qingsheng Ren 于2024年2月19日周一 17:53写道: > > > > > Hi

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Rui Fan
Congratulations, Jiabao! Best, Rui On Mon, Feb 19, 2024 at 6:07 PM weijie guo wrote: > Congratulations, Jiabao :) > > Best regards, > > Weijie > > > Hang Ruan 于2024年2月19日周一 18:04写道: > > > Congratulations, Jiabao! > > > > Best, > > Hang > > > > Qingsheng Ren 于2024年2月19日周一 17:53写道: > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread weijie guo
Congratulations, Jiabao :) Best regards, Weijie Hang Ruan 于2024年2月19日周一 18:04写道: > Congratulations, Jiabao! > > Best, > Hang > > Qingsheng Ren 于2024年2月19日周一 17:53写道: > > > Hi everyone, > > > > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink > > Committer. > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Hang Ruan
Congratulations, Jiabao! Best, Hang Qingsheng Ren 于2024年2月19日周一 17:53写道: > Hi everyone, > > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink > Committer. > > Jiabao began contributing in August 2022 and has contributed 60+ commits > for Flink main repo and various

[jira] [Created] (FLINK-34465) Python py38-cython: commands failed, Bash exited with code '1

2024-02-19 Thread lincoln lee (Jira)
lincoln lee created FLINK-34465: --- Summary: Python py38-cython: commands failed, Bash exited with code '1 Key: FLINK-34465 URL: https://issues.apache.org/jira/browse/FLINK-34465 Project: Flink

[ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-19 Thread Qingsheng Ren
Hi everyone, On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink Committer. Jiabao began contributing in August 2022 and has contributed 60+ commits for Flink main repo and various connectors. His most notable contribution is being the core author and maintainer of MongoDB

[jira] [Created] (FLINK-34464) actions/cache@v4 times out

2024-02-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34464: - Summary: actions/cache@v4 times out Key: FLINK-34464 URL: https://issues.apache.org/jira/browse/FLINK-34464 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34463) Open catalog in CatalogManager should use proper context classloader

2024-02-19 Thread jrthe42 (Jira)
jrthe42 created FLINK-34463: --- Summary: Open catalog in CatalogManager should use proper context classloader Key: FLINK-34463 URL: https://issues.apache.org/jira/browse/FLINK-34463 Project: Flink

[RESULT][VOTE] Release flink-connector-mongodb 1.1.0, release candidate #2

2024-02-19 Thread Leonard Xu
I'm happy to announce that we have unanimously approved this release. There are 6 approving votes, 3 of which are binding: * Jiabao Sun (non-binding) * gongzhongqiang (non-binding) * Hang Ruan (non-binding) * Danny Cranmer (binding) * Martijn Visser (binding) * Leonard Xu (binding) There are

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

2024-02-19 Thread Leonard Xu
Thanks all for the voting, I’ll summarize the result in another mail. Best, Leonard > 2024年2月19日 下午4:46,Leonard Xu 写道: > > +1 (binding) > > - built from source code succeeded > - verified signatures > - verified hashsums > - checked the contents contains jar and pom files in apache repo >

[jira] [Created] (FLINK-34462) Session window with negative parameter throws unclear exception

2024-02-19 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-34462: Summary: Session window with negative parameter throws unclear exception Key: FLINK-34462 URL: https://issues.apache.org/jira/browse/FLINK-34462 Project: Flink

[jira] [Created] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

2024-02-19 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34461: -- Summary: MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17 Key: FLINK-34461 URL: https://issues.apache.org/jira/browse/FLINK-34461 Project:

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

2024-02-19 Thread Leonard Xu
+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked the contents contains jar and pom files in apache repo - checked Github release tag - checked release notes Best, Leonard > 2024年2月8日 下午11:37,Martijn Visser 写道: > > +1 (binding) > > -