Re: flink version stable

2024-03-30 Thread Lincoln Lee
specific connectors on the mailing list. [1] https://lists.apache.org/thread/7qr8jc053y8xpygcwbhlqq4r7c7fj1p3 [2] https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development [3] https://lists.apache.org/thread/sz7f4o1orh96zgjjztcp5gh85l3ks26x Best, Lincoln Lee Fokou Toukam

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

2024-03-20 Thread Lincoln Lee
Congrats, thanks for the great work! Best, Lincoln Lee Peter Huang 于2024年3月20日周三 22:48写道: > Congratulations > > > Best Regards > Peter Huang > > On Wed, Mar 20, 2024 at 6:56 AM Huajie Wang wrote: > >> >> Congratulations >> >> >> >>

[ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Lincoln Lee
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 stream processing framework for distributed, high-performing, always-available, and accurate data streaming applicat

Re: [DISCUSS][FLINK-32993] Datagen connector handles length-constrained fields according to the schema definition by default

2023-11-21 Thread Lincoln Lee
h semantics for varchar, since the length 128 in varchar(128) is just max length, we can extending datagen to generate variable length values(maybe a new option to enable it, e.g., 'fields.f0.var-len'='true'). Of course, this is a new feature that is not part of this problem. Be

[SUMMARY] Flink 1.19 Release Sync 11/14/2023

2023-11-15 Thread Lincoln Lee
Hi devs and users, Yesterday was the first release sync of Flink 1.19, I’d like to share the summary: - Sync meeting We switched back to google meet because there's some account limitation for zoom on some region and the google meet is available when creator is not online. The meeting will happen

Re: [ANNOUNCE] Apache Flink 1.18.0 released

2023-10-26 Thread Lincoln Lee
Thanks for the great work! Congrats all! Best, Lincoln Lee Jing Ge 于2023年10月27日周五 00:16写道: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.18.0, which is the first release for the Apache Flink 1.18 series. > > Apache Flink® is an open-so

Re: [DISCUSS][FLINK-31788][FLINK-33015] Add back Support emitUpdateWithRetract for TableAggregateFunction

2023-09-07 Thread Lincoln Lee
back), I'd recommend holding off on removing `TableAggregateFunction` until we have a replacement for it, e.g., user-defined-operator as Jark mentioned or something else. Best, Lincoln Lee Best, Lincoln Lee Jark Wu 于2023年9月7日周四 21:30写道: > +1 to fix it first. > > I also agree to depre

Re: AsyncDataStream: Retries keep executing after timeout

2022-12-21 Thread Lincoln Lee
& testProcessingTimeWithTimeoutFunctionOrderedWithRetry. You can wait for the fix after merge or try the patch if urgently needed. Thanks again for reporting this! Best, Lincoln Lee Yoni Gibbs 于2022年12月15日周四 18:10写道: > Hi Lincoln, > > Thanks very much for the reply! The issue seems

Re: AsyncDataStream: Retries keep executing after timeout

2022-12-14 Thread Lincoln Lee
t the problem is. Best, Lincoln Lee Yoni Gibbs 于2022年12月13日周二 23:46写道: > Hi, > > I've got a Kinesis consumer which reacts to each record by doing some > async work using an implementation of RichAsyncFunction. I'm adding a > retry strategy. After x failed attempts I wan