Re: Fwd: Custom Windowing Strategies in SQL

Hi Justin, Flink SQL is currently not extensible enough for this task. And FLIP-440 [1] aims to change that. It will expose functionality requested by many advanced use cases. Until this FLIP has been accepted by the community, a solution would consist of a mixture of Flink SQL and DataStream

Re: [DISCUSS] Flink external connector bump version

Hi, Yanquan. Thanks for this discussion. Flink 1.20 has been released for two months and only kafka connector supports this version by now. It is reasonable to create an issue to track this content. For connectors whose latest supported version are 1.17(ES & HBase & RabbitMQ), I am considering wh

[RESULT][VOTE] Release 2.0-preview1, release candidate #1

Hi everyone, I'm happy to announce that we have unanimously approved this preview release. There are 13 approving votes, 9 of which are binding: - Xintong Song (binding) - Junrui Lee (non-binding) - Weijie Guo (binding) - Lincoln Lee (binding) - Zhu Zhu (binding) - Yuan Mei (binding) - Rui Fan (

Re: [VOTE] Release 2.0-preview1, release candidate #1

Thank you all for voting. I'm closing the vote in another thread. Best, Xintong On Fri, Oct 18, 2024 at 5:47 AM Xingbo Huang wrote: > +1 (binding) > > - Verified checksum > - Build PyFlink from source code (M2 Pro, JDK11, Python 3.10). > - Run a PyFlink Table API and UDF example. > > Best,

[jira] [Created] (FLINK-36574) The file STDOUT is not available on the TaskExecutor

fangmin.yang created FLINK-36574: Summary: The file STDOUT is not available on the TaskExecutor Key: FLINK-36574 URL: https://issues.apache.org/jira/browse/FLINK-36574 Project: Flink Issue Ty

[jira] [Created] (FLINK-36573) Add table information of binlog offsets when checkpointing

Runkang He created FLINK-36573: -- Summary: Add table information of binlog offsets when checkpointing Key: FLINK-36573 URL: https://issues.apache.org/jira/browse/FLINK-36573 Project: Flink Issue