The GitHub Actions job "Weekly Flink Connector Kafka CI" on flink-connector-kafka.git/main has failed. Run started by GitHub user MartijnVisser (triggered by MartijnVisser).
Head commit for run: aa6be4bac8aeab15b471820f037fcf3cecca044c / lnbest0707 <[email protected]> [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release (#283) This implements FLINK-40094 as the mandatory correctness follow-up to FLINK-39979 and #276. #276 correctly marks the DynamicKafkaSource reader's main output idle when metadata removal leaves a source subtask without active subreaders. Flink also maintains split-local outputs for source watermark aggregation, however, and directly calling releaseOutputForSplit does not recompute or publish their aggregate watermark/idleness. A removed split that was active can therefore leave the subtask output active and pin the downstream watermark even after the main reader output becomes idle. This change marks each removed split output idle immediately before releasing it. That forces Flink to publish the updated aggregate state before the split-local output is unregistered. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/29667371405 With regards, GitHub Actions via GitBox
