Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

Congratz! On Mon, Apr 7, 2025 at 6:44 AM Ferenc Csaky wrote: > Congrats, Sergey! > > Best, > Ferenc > > > On Monday, April 7th, 2025 at 03:30, weijie guo > wrote: > > > > > > > Congratulations, Sergey~ > > > > Best regards, > > > > Weijie > > > > > > Lincoln Lee lincoln.8...@gmail.com 于2025年4月3

Kafka connector 4.0.0 release

Hi folks, I would like to volunteer to drive the Kafka connector 4.0.0 release to make the connector finally available to Flink 2.0. If there are no objections, I'd start tomorrow with the branch cut. LMK if there are any issues that should be merged until then. Best, Arvid

[jira] [Created] (FLINK-37621) EnableAsyncState doesn't seem to do anything on DataStream API and misleading error message

Gyula Fora created FLINK-37621: -- Summary: EnableAsyncState doesn't seem to do anything on DataStream API and misleading error message Key: FLINK-37621 URL: https://issues.apache.org/jira/browse/FLINK-37621

Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector

Hi Hongshun, 1. In case of unsupported API, the kafka-client library throws an error, which will failover in Flink. We could make the error more user friendly but I think fail over is correct instead of silently switching to an undesired strategy. David already asked if we could check that during

Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

Congrats, Sergey! Best, Ferenc On Monday, April 7th, 2025 at 03:30, weijie guo wrote: > > > Congratulations, Sergey~ > > Best regards, > > Weijie > > > Lincoln Lee lincoln.8...@gmail.com 于2025年4月3日周四 18:14写道： > > > Congratulations, Sergey! > > > > Best, > > Lincoln Lee > > > > Yuepen

Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector

Hi Heise, This sounds like a good idea. Just some tiny questions left: 1. Behavior when ListTransactions is unsupported: If the server does not support the ListTransactions API, what should the system’s behavior be? - Should it throw an exception to signal incompatibility? -

[jira] [Created] (FLINK-37620) ForSt Sync mode support remote storage and provide configurable options

Zakelly Lan created FLINK-37620: --- Summary: ForSt Sync mode support remote storage and provide configurable options Key: FLINK-37620 URL: https://issues.apache.org/jira/browse/FLINK-37620 Project: Flink

[jira] [Created] (FLINK-37619) cdcpiple sink paimon meet IllegalArgumentException when add column

linqichen created FLINK-37619: - Summary: cdcpiple sink paimon meet IllegalArgumentException when add column Key: FLINK-37619 URL: https://issues.apache.org/jira/browse/FLINK-37619 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

Congratulations, Sergey~ Best regards, Weijie Lincoln Lee 于2025年4月3日周四 18:14写道： > Congratulations, Sergey! > > > Best, > Lincoln Lee > > > Yuepeng Pan 于2025年4月3日周四 17:48写道： > > > Congratulations! > > > > Best regards, > > Yuepeng Pan > > > > > > > > > > > > > > At 2025-04-03 17:42:21, "Sheng