[
https://issues.apache.org/jira/browse/FLINK-40622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-40622:
-----------------------------------
Labels: test-stability (was: )
> SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the
> job to fail with "Topic ... is missing"
> --------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-40622
> URL: https://issues.apache.org/jira/browse/FLINK-40622
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: kafka-5.1.0
> Reporter: Martijn Visser
> Priority: Major
> Labels: test-stability
>
> Three occurrences, one before and two after FLINK-40589 raised the wait from
> 2 s to 20 s:
> -
> https://github.com/apache/flink-connector-kafka/actions/runs/34116575758/job/101724687796
> (main, 2026-09-07, JDK 17, parameterization [2], 45.43 s)
> -
> https://github.com/apache/flink-connector-kafka/actions/runs/34343298307/job/102637207151
> (PR #289, 2026-09-09, JDK 17, [1], 48.86 s)
> -
> https://github.com/apache/flink-connector-kafka/actions/runs/34392134730/job/102602782562
> (PR #305, 2026-09-09, JDK 11, [2], 63.22 s)
> {code}
> [ERROR]
> org.apache.flink.connector.kafka.source.SourceTopicIntegrityTest.testTopicIntegrityFailure(SourceSubscriptionMode,
> boolean, MiniCluster)[1] -- Time elapsed: 48.86 s <<< ERROR!
> java.util.concurrent.TimeoutException: Waiting for job to fail with
> org.apache.flink.connector.kafka.source.enumerator.metadata.TopicIntegrityException:
> Topic SourceTopicIntegrityTest_source-topic is missing
> at
> org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:218)
> at
> org.apache.flink.connector.kafka.source.SourceTopicIntegrityTest.testTopicIntegrityFailure(SourceTopicIntegrityTest.java:206)
> {code}
> In each job log the SourceCoordinator reports the job failing repeatedly with
> the other integrity message during the class run, for example (job
> 102637207151):
> {code}
> 22:27:48,944 [SourceCoordinator-Source: kafka-source] ERROR
> org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext [] -
> Exception while handling result from async call in SourceCoordinator-Source:
> kafka-source. Triggering job failover.
> ...
>
> Caused by:
> org.apache.flink.connector.kafka.source.enumerator.metadata.TopicIntegrityException:
> Topic SourceTopicIntegrityTest_source-topic was recreated
> {code}
> Counts of "Caused by: ... TopicIntegrityException" lines per job log, all
> parameterizations of the class included: 102637207151: "was recreated" 405,
> "is missing" 4; 101724687796: 10 and 6; 102602782562: 404 and 8. The class
> runs in the unit-test surefire execution with forkCount=4 (FLINK-40618), so
> the log interleaves other forks.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
