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

Congratulations! Best, Ron Jark Wu 于2024年3月21日周四 10:46写道： > Congratulations and welcome! > > Best, > Jark > > On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote: > > > Congratulations! > > > > Best, > > Rui > > > > On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan > wrote: > > > > > C

Re: [ANNOUNCE] Apache Flink 1.19.0 released

Congratulations Best, Ron Yanfei Lei 于2024年3月18日周一 20:01写道： > Congrats, thanks for the great work! > > Sergey Nuyanzin 于2024年3月18日周一 19:30写道： > > > > Congratulations, thanks release managers and everyone involved for the > great work! > > > > On Mon, Mar 18, 2024 at 12:15 PM Benchao Li > wrot

Re: Temporal join on rolling aggregate

+1, But I think this should be a more general requirement, that is, support for declaring watermarks in query, which can be declared for any type of source, such as table, view. Similar to databricks provided [1], this needs a FLIP. [1] https://docs.databricks.com/en/sql/language-manual/sql-ref-sy

Re: Long execution of SQL query to Kafka + Hive (q77 TPC-DS)

Hi, Can you help to explain the q77 execution plan? And find which operator takes a long time in flink UI? Best Ron Вова Фролов 于2024年1月24日周三 09:09写道： > Hello, > > I am executing a heterogeneous SQL query (part of the data is in Hive > and part in Kafka. The query utilizes TPC-DS benchmark 10