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: d793250521b3cc4910651f59a099ebaed0683436 / Sylwester Lachiewicz <[email protected]> [hotfix] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest hasLatestMetadataUpdateEvent() polls getLatestMetadataUpdateEventWithoutContextSync(), which reads MockSplitEnumeratorContext's internal sentSourceEvent list via reflection directly from the JUnit test thread, bypassing the context's single-threaded main executor. The enumerator's metadata discovery thread appends to that same list via sendEventToSourceReader() (correctly serialized through the main executor), so a test thread iterating the list via Stream.reduce() while that thread appends to it occasionally throws ConcurrentModificationException instead of the intended AssertionError "not ready yet" signal. Catch ConcurrentModificationException alongside AssertionError so the existing CommonTestUtils.waitUtil(...) polling loop retries instead of failing the test. Co-Authored-By: Claude Sonnet 5 <[email protected]> Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/29204695279 With regards, GitHub Actions via GitBox
