This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit cd3ffa5365cfe9461533e7b047d458caf7040a08 Author: Piotr Nowojski <[email protected]> AuthorDate: Mon Sep 21 18:17:20 2020 +0200 [backport] Relevant test mock changes from "[FLINK-18907][task] Fix and add test coverage for watermarks gauges with chained sources" --- .../org/apache/flink/api/connector/source/mocks/MockSourceReader.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceReader.java b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceReader.java index 58ae951..4910f74 100644 --- a/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceReader.java +++ b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceReader.java @@ -47,6 +47,7 @@ public class MockSourceReader implements SourceReader<Integer, MockSourceSplit> public MockSourceReader() { this(false); } + public MockSourceReader(boolean waitingForMoreSplits) { this.started = false; this.closed = false; @@ -149,6 +150,9 @@ public class MockSourceReader implements SourceReader<Integer, MockSourceSplit> return receivedSourceEvents; } + /** + * Simple event allowing {@link MockSourceReader} to finish when requested. + */ public static class MockNoMoreSplitsEvent implements SourceEvent { } }
