Re: [DISCUSS]: Flink code generation porting to Calcite

Thanks Sergey. I’m treating JavaCodeSplitter.split() as the “entry point” for the code-splitter. This method fails if I exclude flink-core because it uses the (Flink) Preconditions class at runtime. I’m prototyping this work in the following Calcite PR: https://github.com/apache/calcite/pull/39

Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

Thanks Zdenek for addressing the comments. I copied the draft into the FLIP collection under FLIP-472 [1]. Looks like there are no additional comments. Feel free to open a voting thread on this proposal. Best, Matthias [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-472%3A+Aligning+tim

[jira] [Created] (FLINK-35970) Update documentation about FLINK-26050 (small file compaction)

Roman Khachatryan created FLINK-35970: - Summary: Update documentation about FLINK-26050 (small file compaction) Key: FLINK-35970 URL: https://issues.apache.org/jira/browse/FLINK-35970 Project: Fli

Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting

+1 (binding) Regards, Roman On Wed, Jul 31, 2024 at 2:39 PM Rui Fan <1996fan...@gmail.com> wrote: > +1(binding) > > Best, > Rui > > Timo Walther 于2024年7月31日 周三17:47写道： > > > +1 (binding) > > > > Thanks for fixing this critical bug. > > > > Regards, > > Timo > > > > On 31.07.24 09:51, Stefan Ric

[jira] [Created] (FLINK-35969) Remove deprecated dataset based API from State Processor API

Gabor Somogyi created FLINK-35969: - Summary: Remove deprecated dataset based API from State Processor API Key: FLINK-35969 URL: https://issues.apache.org/jira/browse/FLINK-35969 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Thanks for the effort to the release mgrs and everyone involved! Best, Ferenc On Friday, 2 August 2024 at 12:16, Jiadong Lu wrote: > > > Congrats! > Best regards, > Jiadong Lu > > On 2024/8/2 18:13, Aleksandr Pilipenko wrote: > > > Congrats! > > > > Best, > > Aleksandr > > >

[jira] [Created] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

Hongshun Wang created FLINK-35968: - Summary: Remove flink-cdc-runtime depedency from connectors Key: FLINK-35968 URL: https://issues.apache.org/jira/browse/FLINK-35968 Project: Flink Issue Ty

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Best regards, Jiadong Lu On 2024/8/2 18:13, Aleksandr Pilipenko wrote: Congrats! Best, Aleksandr On Fri, 2 Aug 2024 at 11:11, Feng Jin wrote: Congratulations! Thanks to release managers and everyone involved! Best, Feng Jin On Fri, Aug 2, 2024 at 5:45 PM Yubin Li wrote: Cong

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Best, Aleksandr On Fri, 2 Aug 2024 at 11:11, Feng Jin wrote: > Congratulations! > > Thanks to release managers and everyone involved! > > Best, > Feng Jin > > On Fri, Aug 2, 2024 at 5:45 PM Yubin Li wrote: > > > Congrats! > > Thanks to release managers and everyone involved for the e

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congratulations! Thanks to release managers and everyone involved! Best, Feng Jin On Fri, Aug 2, 2024 at 5:45 PM Yubin Li wrote: > Congrats! > Thanks to release managers and everyone involved for the excellent work ! > > Best, > Yubin Li > > On Fri, Aug 2, 2024 at 5:41 PM Paul Lam wrote: > >

[jira] [Created] (FLINK-35967) Shade other Flink connectors in CDC Pipeline connectors

yux created FLINK-35967: --- Summary: Shade other Flink connectors in CDC Pipeline connectors Key: FLINK-35967 URL: https://issues.apache.org/jira/browse/FLINK-35967 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-455: Declare async state processing and checkpoint the in-flight requests

Hi Xuyang, Thanks for your reply! 1. Since declareProcess is introduced in `Input` and > `TwoInputStreamOperator` to > align with `processElement`, do we also need to consider modifying other > clazzes > such as `KeyedProcessFunction` to introduce similar methods? Yes, these APIs will be expose

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Thanks to release managers and everyone involved for the excellent work ! Best, Yubin Li On Fri, Aug 2, 2024 at 5:41 PM Paul Lam wrote: > > Congrats! > > Best, > Paul Lam > > > 2024年8月2日 17:26，Ahmed Hamdy 写道： > > > > Congratulations! > > Thanks Weijie and the release managers for the

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congrats! Best, Paul Lam > 2024年8月2日 17:26，Ahmed Hamdy 写道： > > Congratulations! > Thanks Weijie and the release managers for the huge efforts. > Best Regards > Ahmed Hamdy > > > On Fri, 2 Aug 2024 at 10:15, Zakelly Lan wrote: > >> Congratulations! Thanks to release managers and everyone inv

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congratulations! Thanks Weijie and the release managers for the huge efforts. Best Regards Ahmed Hamdy On Fri, 2 Aug 2024 at 10:15, Zakelly Lan wrote: > Congratulations! Thanks to release managers and everyone involved! > > > Best, > Zakelly > > On Fri, Aug 2, 2024 at 5:05 PM weijie guo > wrot

Re: [ANNOUNCE] Apache Flink 1.20.0 released

Congratulations! Thanks to release managers and everyone involved! Best, Zakelly On Fri, Aug 2, 2024 at 5:05 PM weijie guo wrote: > The Apache Flink community is very happy to announce the release of Apache > > Flink 1.20.0, which is the first release for the Apache Flink 1.20 series. > > > Ap

[ANNOUNCE] Apache Flink 1.20.0 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.20.0, which is the first 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 appl