Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released

2022-06-05 Thread rui fan
Thanks Yang for driving the release, and thanks to all contributors for making this release happen! Best wishes Rui Fan On Sun, Jun 5, 2022 at 4:14 PM Yang Wang wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink Kubernetes Operator 1.0.0. > &g

Re: Kafka source with idleness and alignment stops consuming

2023-06-30 Thread Rui Fan
Hi all, It's really a bug, haishui has created the FLINK-32496[1], let's follow this issue there. [1] https://issues.apache.org/jira/browse/FLINK-32496 Best, Rui Fan On Thu, Jun 29, 2023 at 8:34 PM Alexis Sarda-Espinosa < sarda.espin...@gmail.com> wrote: > BTW, it seems

Re: [ANNOUNCE] Apache Flink 1.18.0 released

2023-10-26 Thread Rui Fan
Thanks for the great work! Best, Rui On Fri, Oct 27, 2023 at 10:03 AM Paul Lam wrote: > Finally! Thanks to all! > > Best, > Paul Lam > > > 2023年10月27日 03:58,Alexander Fedulov 写道: > > > > Great work, thanks everyone! > > > > Best, > > Alexander > > > > On Thu, 26 Oct 2023 at 21:15, Martijn Viss

[ANNOUNCE] Apache Flink Kubernetes Operator 1.6.1 released

2023-10-30 Thread Rui Fan
://hub.docker.com/r/apache/flink-kubernetes-operator The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12353784 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards,

[DISCUSS] Change the default restart-strategy to exponential-delay

2023-11-15 Thread Rui Fan
Hi dear flink users and devs: FLIP-364[1] intends to make some improvements to restart-strategy and discuss updating some of the default values of exponential-delay, and whether exponential-delay can be used as the default restart-strategy. After discussing at dev mail list[2], we hope to collect

Re: [DISCUSS] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-15 Thread Rui Fan
Thanks Junrui for driving this proposal! Overall looks good to me! I have a question: How do the flink users to getGlobalJobParameters if RuntimeContext#getExecutionConfig is removed? Is there any alternative api? Or is this feature removed? Maybe this is a noob question and I may have missed som

Re: [DISCUSS] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-15 Thread Rui Fan
;@PublicEvolving > Map getGlobalJobParameters()" in this FLIP. And this method > will provide users with global job parameters. > I would appreciate it if you could share your thoughts on whether this > addition adequately resolves your concerns. > > Best, > Junrui > >

Re: [DISCUSS] Change the default restart-strategy to exponential-delay

2023-11-19 Thread Rui Fan
posal makes sense to me. Given that the new >> default feels more complex than the current behavior, if we decide to do >> this I think it will be important to include the rationale you've shared in >> the documentation. >> >> David >> >> On Wed, Nov

[ANNOUNCE] Apache Flink 1.16.3 released

2023-11-29 Thread Rui Fan
The Apache Flink community is very happy to announce the release of Apache Flink 1.16.3, which is the third bugfix release for the Apache Flink 1.16 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

Re: [DISCUSS] Change the default restart-strategy to exponential-delay

2023-12-11 Thread Rui Fan
. Another thing > I > > found helpful in the past is to refer to Kubernetes--for example, the > > default strategy is exponential for pod restarts and we could draw > > inspiration from what they have set as a general purpose default config. > > > > Best, > > Mason >

Re: [DISCUSS] Change the default restart-strategy to exponential-delay

2023-12-19 Thread Rui Fan
14 PM Maximilian Michels wrote: > Thank you Rui! I think a 1.5 multiplier is a reasonable tradeoff > between restarting fast but not putting too much pressure on the > cluster due to restarts. > > -Max > > On Tue, Dec 12, 2023 at 8:19 AM Rui Fan <1996fan...@gmail.com> wrote:

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Rui Fan
Congratulations, thanks for the great work! Best, Rui On Mon, Mar 18, 2024 at 4:26 PM Lincoln Lee wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.19.0, which is the fisrt release for the Apache Flink 1.19 series. > > Apache Flink® is an open-source

Re: [ANNOUNCE] Donation Flink CDC into Apache Flink has Completed

2024-03-20 Thread Rui Fan
Congratulations! Best, Rui On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote: > Congrattulations! > > Best, > Hang > > Lincoln Lee 于2024年3月21日周四 09:54写道: > >> >> Congrats, thanks for the great work! >> >> >> Best, >> Lincoln Lee >> >> >> Peter Huang 于2024年3月20日周三 22:48写道: >> >>> Congratulation

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.8.0 released

2024-03-25 Thread Rui Fan
Congratulations! Thanks Max for the release and all involved for the great work! A gentle reminder to users: the maven artifact has just been released and will take some time to complete. Best, Rui On Mon, Mar 25, 2024 at 6:35 PM Maximilian Michels wrote: > The Apache Flink community is very h

Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project

2024-03-28 Thread Rui Fan
Congratulations~ Best, Rui On Thu, Mar 28, 2024 at 3:55 PM Yu Li wrote: > CC the Flink user and dev mailing list. > > Paimon originated within the Flink community, initially known as Flink > Table Store, and all our incubating mentors are members of the Flink > Project Management Committee. I a

Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode?

2024-11-06 Thread Rui Fan
Thanks Yuepeng for the PR and starting this discussion! And thanks Gyula and Yuanfeng for the input! I also agree to fix this behaviour in the 1.x line. The adaptive scheduler and rescaling API provide powerful capabilities to increase or decrease parallelism. The main benefit I understand of d