[jira] [Created] (FLINK-37358) Support pass format options to kafka pipeline sink

2025-02-19 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-37358: -- Summary: Support pass format options to kafka pipeline sink Key: FLINK-37358 URL: https://issues.apache.org/jira/browse/FLINK-37358 Project: Flink Issue Type: Im

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread ConradJam
Congratulations, Xuyang! Jingsong Li 于2025年2月20日周四 13:18写道: > Congratulations, Xuyang! > > Best, > Jingsong > > On Thu, Feb 20, 2025 at 1:10 PM Sergey Nuyanzin > wrote: > > > > Congratulations, Xuyang! > > > > On Thu, Feb 20, 2025, 04:30 Hongshun Wang > wrote: > > > > > Congratulations, Xuyan

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Jingsong Li
Congratulations, Xuyang! Best, Jingsong On Thu, Feb 20, 2025 at 1:10 PM Sergey Nuyanzin wrote: > > Congratulations, Xuyang! > > On Thu, Feb 20, 2025, 04:30 Hongshun Wang wrote: > > > Congratulations, Xuyang! You deserve it > > Best, > > Hongshun > > > > On Thu, Feb 20, 2025 at 11:26 AM Shawn H

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Sergey Nuyanzin
Congratulations, Xuyang! On Thu, Feb 20, 2025, 04:30 Hongshun Wang wrote: > Congratulations, Xuyang! You deserve it > Best, > Hongshun > > On Thu, Feb 20, 2025 at 11:26 AM Shawn Huang wrote: > > > Congratulations ! > > > > Best, > > Shawn Huang > > > > > > Yanquan Lv 于2025年2月20日周四 11:05写道: >

[jira] [Created] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
Hirson Zhang created FLINK-37357: Summary: Migrating conversion logic to SqlNodeConverters Key: FLINK-37357 URL: https://issues.apache.org/jira/browse/FLINK-37357 Project: Flink Issue Type: I

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Hongshun Wang
Congratulations, Xuyang! You deserve it Best, Hongshun On Thu, Feb 20, 2025 at 11:26 AM Shawn Huang wrote: > Congratulations ! > > Best, > Shawn Huang > > > Yanquan Lv 于2025年2月20日周四 11:05写道: > > > Congratulations, Xuyang! > > > > Best, Yanquan. > > > > > 2025年2月20日 10:24,Zakelly Lan 写道: > > >

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Shawn Huang
Congratulations ! Best, Shawn Huang Yanquan Lv 于2025年2月20日周四 11:05写道: > Congratulations, Xuyang! > > Best, Yanquan. > > > 2025年2月20日 10:24,Zakelly Lan 写道: > > > > Congratulations, Xuyang! > >

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Yanquan Lv
Congratulations, Xuyang! Best, Yanquan. > 2025年2月20日 10:24,Zakelly Lan 写道: > > Congratulations, Xuyang!

退订

2025-02-19 Thread 于峰13
退订

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Jacky Lau
Congratulations, you deserve it. Best, Jacky yh z 于2025年2月20日周四 10:01写道: > Congratulations > > Best, > Ron > > Ron Liu 于2025年2月20日周四 09:56写道: > > > Congratulations, you deserve it. > > > > Best, > > Ron > > > > > > Lincoln Lee 于2025年2月20日周四 09:50写道: > > > > > Hi everyone, > > > > > > On behal

退订

2025-02-19 Thread 李乐
退订

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Zakelly Lan
Congratulations, Xuyang! Best, Zakelly On Thu, Feb 20, 2025 at 10:21 AM Jacky Lau wrote: > Congratulations, you deserve it. > > Best, > Jacky > > yh z 于2025年2月20日周四 10:01写道: > > > Congratulations > > > > Best, > > Ron > > > > Ron Liu 于2025年2月20日周四 09:56写道: > > > > > Congratulations, you dese

退订

2025-02-19 Thread 李乐
退订

[jira] [Created] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest

2025-02-19 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-37356: - Summary: Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest Key: FLINK-37356 URL: https://issues.apache.org/jira/browse/FLINK-373

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Junrui Lee
Congratulations! Best, Junrui yh z 于2025年2月20日周四 10:00写道: > Congratulations > > Best, > Ron > > Ron Liu 于2025年2月20日周四 09:56写道: > > > Congratulations, you deserve it. > > > > Best, > > Ron > > > > > > Lincoln Lee 于2025年2月20日周四 09:50写道: > > > > > Hi everyone, > > > > > > On behalf of the PMC, I

[ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Lincoln Lee
Hi everyone, On behalf of the PMC, I'm happy to announce that Xuyang has become a new Flink Committer! Xuyang has been contributing to the Flink community since Sep 15, 2021, he has driven and contributed to 5 FLIPs, submitted over 100 commits and more than 100,000 lines of code changes. He prim

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread yh z
Congratulations Best, Ron Ron Liu 于2025年2月20日周四 09:56写道: > Congratulations, you deserve it. > > Best, > Ron > > > Lincoln Lee 于2025年2月20日周四 09:50写道: > > > Hi everyone, > > > > On behalf of the PMC, I'm happy to announce that Xuyang has become a > > new Flink Committer! > > > > Xuyang has been

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Shengkai Fang
Congratulations! Best, Shengkai Lincoln Lee 于2025年2月20日周四 09:50写道: > Hi everyone, > > On behalf of the PMC, I'm happy to announce that Xuyang has become a > new Flink Committer! > > Xuyang has been contributing to the Flink community since Sep 15, 2021, he > has > driven and contributed to 5 FL

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

2025-02-19 Thread Ron Liu
Congratulations, you deserve it. Best, Ron Lincoln Lee 于2025年2月20日周四 09:50写道: > Hi everyone, > > On behalf of the PMC, I'm happy to announce that Xuyang has become a > new Flink Committer! > > Xuyang has been contributing to the Flink community since Sep 15, 2021, he > has > driven and contrib

[jira] [Created] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint.

2025-02-19 Thread longwang0616 (Jira)
longwang0616 created FLINK-37355: Summary: When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. Key: FLINK-37355 URL: https://iss

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

2025-02-19 Thread xiangyu feng
Hi all, Thank you all for the comments. If there is no further comment, I will open the voting thread in 3 days. Regards, Xiangyu Ron Liu 于2025年2月19日 周三17:58写道: > Hi, Xiangyu > > Thaks for updates, LGTM > > Best, > Ron > > xiangyu feng 于2025年2月19日周三 17:13写道: > >> Hi Ron, >> >> Thx for ur adv

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

2025-02-19 Thread Danny Cranmer
Hello Poorvank, Thanks for opening this discussion/FLIP. I am +1 for the idea, it seems like a great enhancement to the AsyncSink. Just one question/observation from me. We currently use a "Deque<..> bufferedRequestEntries". Now we are exposing these batch creators; it might not make sense to use

Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

2025-02-19 Thread Becket Qin
Sorry for the late reply. I have a question regarding the configuration of interval. I am wondering in which scenario the interval config will actually be used. Is the interval configuration only useful for windowed aggregation? For the join operations, early fire seems only applicable to the oute

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

2025-02-19 Thread Hao Li
+1 (non-binding) Thanks Yash, Hao On Tue, Feb 18, 2025 at 10:46 AM Yash Anand wrote: > Hi Everyone, > > I'd like to start a vote on FLIP-507: Add Model DDL methods in TABLE API > [1] which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an

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

2025-02-19 Thread Alexander Fedulov
It is now. It took a while to get the official Docker images out. Best, Alex On Thu, 13 Feb 2025 at 08:05, Zach Zhang wrote: > > Hi Alex > > Has Flink 1.19.2 released? If not, when will be the target date? > > Leonard Xu 于2025年2月12日周三 09:57写道: > > > Thanks Alex for driving this release, Good J

Re: [ANNOUNCE] Apache Flink 1.20.1 released

2025-02-19 Thread Ferenc Csaky
Congrats to everyone involved! Thanks Alex for managing the release! Best, Ferenc On Wednesday, February 19th, 2025 at 15:56, Alexander Fedulov wrote: > > > I would also like to explicitly thank Ferenc Csaky, Sergey Nuyanzin, > Matthias Pohl, Marton Balassi, Max Michels, and David Radley f

Re: [ANNOUNCE] Apache Flink 1.19.2 released

2025-02-19 Thread Ferenc Csaky
Congrats to everyone involved! Thanks Alex for managing the release! Best, Ferenc On Wednesday, February 19th, 2025 at 15:59, Alexander Fedulov wrote: > > > I would also like to explicitly thank Ferenc Csaky, Sergey Nuyanzin, > Matthias Pohl, Marton Balassi, Max Michels, and David Radley f

Re: [VOTE] Release flink-shaded 20.0, release candidate #1

2025-02-19 Thread Dawid Wysakowicz
+1 (binding) * Verified the signature and checksum * checked the website PR * checked there are no binaries in the source release Best, Dawid On Tue, 18 Feb 2025 at 18:52, Sergey Nuyanzin wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the version > 20.0, as foll

Re: [ANNOUNCE] Apache Flink 1.19.2 released

2025-02-19 Thread Alexander Fedulov
I would also like to explicitly thank Ferenc Csaky, Sergey Nuyanzin, Matthias Pohl, Marton Balassi, Max Michels, and David Radley for their assistance during PR triaging and the release preparation process. Per our release process, could someone with PMC permissions please update Apache reports?

[ANNOUNCE] Apache Flink 1.19.2 released

2025-02-19 Thread Alexander Fedulov
The Apache Flink community is very happy to announce the release of Apache Flink 1.19.2, which is the second bugfix release for the Apache Flink 1.19 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

Re: [ANNOUNCE] Apache Flink 1.20.1 released

2025-02-19 Thread Alexander Fedulov
I would also like to explicitly thank Ferenc Csaky, Sergey Nuyanzin, Matthias Pohl, Marton Balassi, Max Michels, and David Radley for their assistance during PR triaging and the release preparation process. Per our release process, could someone with PMC permissions please update Apache reports?

[DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs

2025-02-19 Thread Mika Naylor
Hi everyone, I'd like to start a discussion about adding API stability annotations to PyFlink, similar to those currently used in the Java APIs (@PublicEvolving, @Experimental, etc.). Currently, the Java APIs use annotations like @PublicEvolving and @Experimental to clearly indicate the stabil

[ANNOUNCE] Apache Flink 1.20.1 released

2025-02-19 Thread Alexander Fedulov
The Apache Flink community is very happy to announce the release of Apache Flink 1.20.1, which is the first bugfix release for the Apache Flink 1.20 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming a

[jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility

2025-02-19 Thread Anton Solovev (Jira)
Anton Solovev created FLINK-37354: - Summary: Kubernetes Operator HealthCheck compatibility Key: FLINK-37354 URL: https://issues.apache.org/jira/browse/FLINK-37354 Project: Flink Issue Type: B

[jira] [Created] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink

2025-02-19 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37353: -- Summary: [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Key: FLINK-37353 URL: https://issues.apache.org/jira/browse/FLINK-37353 Project: Fl

[jira] [Created] (FLINK-37352) Write full changelog to Paimon Sink.

2025-02-19 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37352: -- Summary: Write full changelog to Paimon Sink. Key: FLINK-37352 URL: https://issues.apache.org/jira/browse/FLINK-37352 Project: Flink Issue Type: Improvement

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

2025-02-19 Thread Ron Liu
Hi, Xiangyu Thaks for updates, LGTM Best, Ron xiangyu feng 于2025年2月19日周三 17:13写道: > Hi Ron, > > Thx for ur advice. I've made the changes to current FLIP[1] including > renaming the interface and remove the default implementation. As we have > discussed, the target columns will be compared in

Re: [VOTE] Release flink-shaded 20.0, release candidate #1

2025-02-19 Thread Timo Walther
+1 (binding) I went through the commit and checked for suspicious changes. Could not found any. Thanks, Timo On 18.02.25 18:52, Sergey Nuyanzin wrote: Hi everyone, Please review and vote on the release candidate #1 for the version 20.0, as follows: [ ] +1, Approve the release [ ] -1, Do not

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

2025-02-19 Thread xiangyu feng
Hi Ron, Thx for ur advice. I've made the changes to current FLIP[1] including renaming the interface and remove the default implementation. As we have discussed, the target columns will be compared in sink reuse if the sink has not implemented the `SupportsTargetColumnWriting` ability. This will

[jira] [Created] (FLINK-37351) Ensure writer and committer are colocated

2025-02-19 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-37351: --- Summary: Ensure writer and committer are colocated Key: FLINK-37351 URL: https://issues.apache.org/jira/browse/FLINK-37351 Project: Flink Issue Type: Bug

[SUMMARY] Flink 2.0 Release Sync 02/19/2015

2025-02-19 Thread Xintong Song
Hi devs, Here's the summary of today's release sync. - There are 3 documentation tickets are still in progress - Cross-team verification - All tickets have added instructions and assigned with testers - 16 / 30 tickets are closed - There's 1 testability brocker, and 1 non-tes