The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/main has failed. Run started by GitHub user bowenli86 (triggered by bowenli86).
Head commit for run: 904e88213ac4988087499c5621fe5c4c2a6ca4f9 / bowenli86 <[email protected]> [FLINK-39979] DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders (#276) DynamicKafkaSource can remain active after a metadata update removes the last active Kafka cluster/split from a reader subtask. Since no sub-reader remains to report idleness, downstream watermark progress can stall. When the reader is already waiting on isAvailable(), resetting availability to zero sub-readers also leaves the cached availability future incomplete, so pollNext() is not invoked to release pending split outputs or mark the output idle. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/28250172985 With regards, GitHub Actions via GitBox
