Re: [DISCUSS] FLIP-208: Update KafkaSource to detect EOF based on de-serialized record

Hi Martijn and Qingsheng, The FLIP has been updated to extend the dynamic EOF support for the PulsarSource. I have not extended this feature to other sources yet since I am not sure it is a requirement to ensure feature consistency across different sources. Could you take another look? Thanks, Do

[jira] [Created] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

Darron Fuller created FLINK-25579: - Summary: Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist Key: FLINK-25579 URL: https://issues.apache.org/jira/browse/FLINK-25579

[jira] [Created] (FLINK-25580) Minor improvements for RocksDBIncrementalCheckpointUtils

Aitozi created FLINK-25580: -- Summary: Minor improvements for RocksDBIncrementalCheckpointUtils Key: FLINK-25580 URL: https://issues.apache.org/jira/browse/FLINK-25580 Project: Flink Issue Type: Impr