[ANNOUNCE] New Apache Flink Committer - Feng Jin

Hi everyone, On behalf of the PMC, I'm happy to announce that Feng Jin has become a new Flink Committer! Feng Jin started contributing to the Apache Flink project on Nov 7, 2020 and has been active for two years, driving and contributing to 6 FLIPs, completed 70+ commits with tens of thousands of

[DISCUSSION] Upgrade to Kryo 5 for Flink 2.0

Hey all! I would like to rekindle this discussion as it seems that it has stalled several times in the past and we are nearing the point in time where the decision has to be made with regards to 2.0. (we are already a bit late but nevermind) There has been numerous requests and efforts to upgrade

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

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> 写道： > >Congratulations! > > > >Best, > >Zuo Wei > > > > > >-- 原始邮件 -- >

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

Congratulations, Xuyang! Best, Feng Jin On Thu, Feb 20, 2025 at 5:44 PM gongzhongqiang wrote: > Congratulations, Xuyang! > > > Best, > Zhongqiang Gong > > 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

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

Hi Mika, thanks for bringing this up! I was actually quite surprised that we don't use any kind of marking in our interfaces in the Python API yet. Your proposal makes total sense. We should reuse the same annotation categories that we use and agreed on in Java. Since the Python Table API is

[jira] [Created] (FLINK-37359) Docker build fails for Kubernetes operator

Gyula Fora created FLINK-37359: -- Summary: Docker build fails for Kubernetes operator Key: FLINK-37359 URL: https://issues.apache.org/jira/browse/FLINK-37359 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

Congratulations, Xuyang! Best, Zhongqiang Gong 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 con

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

+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs Op wo 19 feb 2025 om 16:16 schreef Dawid Wysakowicz > +1 (binding) > > * Verified the signature and checksum > * che

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

Congratulations, Yuyang! Best regards, Weijie ConradJam 于2025年2月20日周四 14:17写道： > 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: > > > > > > Congratul

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>

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

Congratulations Best, Ron Yuepeng Pan 于2025年2月21日周五 09:57写道： > Congratulations ! > > > Best, > Yuepeng. > > > > > > At 2025-02-21 09:52:46, "Lincoln Lee" wrote: > >Hi everyone, > > > >On behalf of the PMC, I'm happy to announce that Feng Jin has become a > >new Flink Committer! > > > >Feng Jin

[jira] [Created] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch

Shuyi Chen created FLINK-37366: -- Summary: Allow configurable retry for Kafka topic metadata fetch Key: FLINK-37366 URL: https://issues.apache.org/jira/browse/FLINK-37366 Project: Flink Issue Typ

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

Congratulations ! Best, Yuepeng. At 2025-02-21 09:52:46, "Lincoln Lee" wrote: >Hi everyone, > >On behalf of the PMC, I'm happy to announce that Feng Jin has become a >new Flink Committer! > >Feng Jin started contributing to the Apache Flink project on Nov 7, 2020 >and >has been active for t

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

Congratulations, Feng Jin ;)-- Best！ Xuyang 在 2025-02-21 11:16:14，"Wei Zuo" <1015766...@qq.com.INVALID> 写道： >Congratulations! > >Best, >Zuo Wei > > >-- 原始邮件 -- >发件人: >

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

Congratulations! Best, Shengkai Ron Liu 于2025年2月21日周五 11:00写道： > Congratulations > > Best, > Ron > > Yuepeng Pan 于2025年2月21日周五 09:57写道： > > > Congratulations ! > > > > > > Best, > > Yuepeng. > > > > > > > > > > > > At 2025-02-21 09:52:46, "Lincoln Lee" wrote: > > >Hi everyone, > > > > > >On b

[jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector

Gabor Somogyi created FLINK-37363: - Summary: Remove confusing and duplicated state.backend.type config from state SQL connector Key: FLINK-37363 URL: https://issues.apache.org/jira/browse/FLINK-37363

[jira] [Created] (FLINK-37360) Update japicmp configuration post 1.20.1

Alexander Fedulov created FLINK-37360: - Summary: Update japicmp configuration post 1.20.1 Key: FLINK-37360 URL: https://issues.apache.org/jira/browse/FLINK-37360 Project: Flink Issue Type

[jira] [Created] (FLINK-37361) Update japicmp configuration post 1.19.2

Alexander Fedulov created FLINK-37361: - Summary: Update japicmp configuration post 1.19.2 Key: FLINK-37361 URL: https://issues.apache.org/jira/browse/FLINK-37361 Project: Flink Issue Type

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

Hi Poorvank, thanks for putting this together. It's obvious to me that this is a good addition. I wish Ahmed could check if his proposals are compatible with yours, so we don't end up with two different ways to express the same thing. Ideally Ahmed's proposal could be retrofitted to extend on your

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

Hi, Thanks for starting this discussion. +1 for the proposal and Timo's addendum regarding the deprecation warning. Best, Ferenc On Thursday, February 20th, 2025 at 11:30, Timo Walther wrote: > > > Hi Mika, > > thanks for bringing this up! I was actually quite surprised that we > don't us

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

Hey Danny, Thank you for the review. Your observation is absolutely valid, and moving away from *Deque> bufferedRequestEntries* in favor of a more flexible abstraction makes sense. *Given the exposure of batch creators, Deque may not be the most semantically appropriate or performant choice. To ad

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

Hey all, Thank you for the feedback! Since it sounds like the runtime warnings wouldn't be too onerous, then I think it'd be good to emit them for deprecated class initialisation and function use. > Actually there exists this kind of mechanism, see the following as an > example which is learned

[jira] [Created] (FLINK-37365) Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs

Mika Naylor created FLINK-37365: --- Summary: Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Key: FLINK-37365 URL: https://issues.apache.org/jira/browse/FLINK-37365 Project:

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

Hey Arvid, Thank you for your feedback and for taking the time to review this proposal. To answer your concerns: *Naming Suggestion: BatchCreationResult → Batch * This is a valid point, and I agree that BatchCreationResult is essentially representing a Batch. The current name was chosen to reflec

[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 T

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

Hi Mika, Thanks a lot for bringing up this discussion. > Currently, the Java APIs use annotations like @PublicEvolving and > @Experimental to clearly indicate the stability status of API components. > This is super helpful for understanding which parts of the API are stable for > production us

[jira] [Created] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC

Ferenc Csaky created FLINK-37364: Summary: Bump Flink 1.19, 1.20 patch versions in Flink CDC Key: FLINK-37364 URL: https://issues.apache.org/jira/browse/FLINK-37364 Project: Flink Issue Type: