Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan

Congratulations!! On Tue, Apr 1, 2025 at 4:02 AM Ferenc Csaky wrote: > Congratulations! > > Best, > Ferenc > > > > On Tuesday, April 1st, 2025 at 11:59, yue ma wrote: > > > > > > > Congratulation, Zakelly! > > > > Junrui Lee jrlee@gmail.com 于2025年4月1日周二 17:38写道： > > > > > Congratulation, Za

[jira] [Created] (FLINK-36156) SinkV2: Provide the ability to set Committer Operator parallelism

Rodrigo Meneses created FLINK-36156: --- Summary: SinkV2: Provide the ability to set Committer Operator parallelism Key: FLINK-36156 URL: https://issues.apache.org/jira/browse/FLINK-36156 Project

SinkV2 framework operators

Hi Flink Devs: I am writing a new Iceberg Sink based on the SinkV2 Flink interface [1]. I have a question regarding the 3 operators that are created behind the scenes by the framework: 1. How can I set the UID on these 3 operators? Ideally, what I would like, is to propagate the UID of the

[jira] [Created] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery

Rodrigo Meneses created FLINK-36058: --- Summary: OperatorTestHarness is always using checkpointId=0 for state recovery Key: FLINK-36058 URL: https://issues.apache.org/jira/browse/FLINK-36058 Project

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

All the best On Wed, Jun 5, 2024 at 5:56 AM xiangyu feng wrote: > Congratulations, Rui! > > Regards, > Xiangyu Feng > > Feng Jin 于2024年6月5日周三 20:42写道： > > > Congratulations, Rui! > > > > > > Best, > > Feng Jin > > > > On Wed, Jun 5, 2024 at 8:23 PM Yanfei Lei wrote: > > > > > Congratulations,

Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction

+1 (non-binding) Thanks a lot for driving this effort!! -Rodrigo On Tue, May 14, 2024 at 11:00 AM Péter Váry wrote: > +1 (non-binding) > Thanks, Peter > > On Tue, May 14, 2024, 09:50 gongzhongqiang > wrote: > > > +1 (non-binding) > > > > Best. > > Zhongqiang Gong > > > > Martijn Visser 于2024年

Re: [ANNOUNCE] Apache Flink 1.19.0 released

Congratulations On Mon, Mar 18, 2024 at 7:43 PM Yu Chen wrote: > Congratulations! > Thanks to release managers and everyone involved! > > Best, > Yu Chen > > > > 2024年3月19日 01:01，Jeyhun Karimov 写道： > > > > Congrats! > > Thanks to release managers and everyone involved. > > > > Regards, > >

Re: Re: Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (non binding) On Fri, Jan 12, 2024 at 5:45 PM Dong Lin wrote: > +1 (binding) > > On Sat, Jan 13, 2024 at 6:04 AM Austin Bennett wrote: > > > +1 (non-binding) > > > > On Fri, Jan 12, 2024 at 5:44 PM Becket Qin wrote: > > > > > +1 (binding) > > > > > > Thanks, > > > > > > Jiangjie (Becket) Qi

Re: [VOTE] FLIP-401: REST API JSON response deserialization unknown field tolerance

+1 On Tue, Dec 12, 2023 at 6:58 AM Maximilian Michels wrote: > +1 (binding) > > On Tue, Dec 12, 2023 at 2:23 PM Peter Huang > wrote: > > > > +1 Non-binding > > > > > > Peter Huang > > > > Őrhidi Mátyás 于2023年12月12日 周二下午9:14写道： > > > > > +1 > > > Matyas > > > > > > On Mon, Dec 11, 2023 at 10:26 

Re: Doc about cleaning savePoints and checkPoints

n.savepoint-restore-mode"). Hope this helps. > > > Best, > Zakelly > > On Fri, Dec 1, 2023 at 3:34 AM Rodrigo Meneses wrote: > > > Hi Flink Community, > > > > I'm searching for docs about how the cleaning of checkpoints and > savepoints > > act

Doc about cleaning savePoints and checkPoints

Hi Flink Community, I'm searching for docs about how the cleaning of checkpoints and savepoints actually work. I'm interested particularly in the cases when the user has `NATIVE` format (incremental savepoint). Somehow, when using NATIVE format, the number of savepoints kept are not matching the

[jira] [Created] (FLINK-31716) Event UID field is missing the first time that an event is consumed

Rodrigo Meneses created FLINK-31716: --- Summary: Event UID field is missing the first time that an event is consumed Key: FLINK-31716 URL: https://issues.apache.org/jira/browse/FLINK-31716 Project