The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/fix-flaky-dynamic-source-enumerator-test has failed. Run started by GitHub user slachiewicz (triggered by slachiewicz).
Head commit for run: 85e4d878b09b73dd6e28bf14ecec9f1a2677aab4 / Sylwester Lachiewicz <[email protected]> [hotfix] Fix idle reader hang when no-more-splits precedes metadata update An idle reader (subtask with no assigned splits) that registers after all bounded sub-enumerators have finished split discovery receives the no-more-splits signal before the MetadataUpdateEvent. The re-notification in handleSourceEvents was guarded by !pendingSplits.isEmpty(), so the sub-readers created by the metadata update were never notified and the reader returned NOTHING_AVAILABLE forever, leaving bounded jobs RUNNING. This caused SourceTestSuiteBase#testIdleReader to hang in CI until the 50-minute global timeout. Re-deliver the no-more-splits signal after processing a metadata update regardless of whether pending splits exist. Co-Authored-By: Claude Fable 5 <[email protected]> Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/29286219044 With regards, GitHub Actions via GitBox
