The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/fix-flaky-dynamic-source-enumerator-test has succeeded. Run started by GitHub user slachiewicz (triggered by slachiewicz).
Head commit for run: 1a06261bce68929b8dc19fc0442ed43a59f171a7 / 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. Verified with 5 repeated local runs of testProductionMetadataRefreshBypassesBlockedSourceCoordinatorAsyncCallable, all passing; this test intermittently failed with this exception in CI before the fix. Co-Authored-By: Claude Sonnet 5 <[email protected]> Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/29191354643 With regards, GitHub Actions via GitBox
