This is an automated email from the ASF dual-hosted git repository. MartijnVisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
commit ebd1a102d748b0f098675fb65827a990ee7e71da Author: MartijnVisser <[email protected]> AuthorDate: Thu Sep 10 15:09:50 2026 +0200 [hotfix][tests] Honour initialDiscoveryFinished in KafkaSourceEnumeratorTest The createEnumerator overload that takes initialDiscoveryFinished dropped it and always built the enumerator state with false, so testWorkWithPreexistingAssignments restored an enumerator that had not finished its initial discovery, which is not what it asks for. Thread the argument through to the state. Generated-by: Claude Code (Claude Opus 5.5) --- .../kafka/source/enumerator/KafkaSourceEnumeratorTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumeratorTest.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumeratorTest.java index cb216aee..07c513ef 100644 --- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumeratorTest.java +++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumeratorTest.java @@ -748,7 +748,8 @@ public class KafkaSourceEnumeratorTest { assignedSplits, unassignedInitialSplits, overrideProperties, - startingOffsetsInitializer); + startingOffsetsInitializer, + initialDiscoveryFinished); } /** @@ -762,7 +763,8 @@ public class KafkaSourceEnumeratorTest { Collection<KafkaPartitionSplit> assignedSplits, Collection<KafkaPartitionSplit> unassignedInitialSplits, Properties overrideProperties, - OffsetsInitializer startingOffsetsInitializer) { + OffsetsInitializer startingOffsetsInitializer, + boolean initialDiscoveryFinished) { // Use a TopicPatternSubscriber so that no exception if a subscribed topic hasn't been // created yet. StringJoiner topicNameJoiner = new StringJoiner("|"); @@ -786,7 +788,8 @@ public class KafkaSourceEnumeratorTest { props, enumContext, Boundedness.CONTINUOUS_UNBOUNDED, - new KafkaSourceEnumState(assignedSplits, unassignedInitialSplits, false)); + new KafkaSourceEnumState( + assignedSplits, unassignedInitialSplits, initialDiscoveryFinished)); } // ---------------------
