You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by bl...@apache.org on 2026/06/26 17:47:02 UTC
(flink-connector-kafka) branch main updated: [hotfix] update reader idleness test output (#281)
This is an automated email from the ASF dual-hosted git repository.
bowenli86 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 6a109ae4 [hotfix] update reader idleness test output (#281)
6a109ae4 is described below
commit 6a109ae49c061b5e07935d0b8551c3914ea4fa8e
Author: bowenli86 <bo...@gmail.com>
AuthorDate: Fri Jun 26 10:46:57 2026 -0700
[hotfix] update reader idleness test output (#281)
---
.../kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
index fea90b72..c7a4ec2a 100644
--- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
+++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReaderTest.java
@@ -342,7 +342,7 @@ public class DynamicKafkaSourceReaderTest extends SourceReaderTestBase<DynamicKa
void testNotifyNoMoreSplits() throws Exception {
TestingReaderContext context = new TestingReaderContext();
try (DynamicKafkaSourceReader<Integer> reader = createReaderWithoutStart(context)) {
- TestingReaderOutput<Integer> readerOutput = new TestingReaderOutput<>();
+ TrackingReaderOutput<Integer> readerOutput = new TrackingReaderOutput<>();
reader.start();
// Splits assigned