This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0d1b476b70bf274d54d94c1c0a16730d91852bc1 Author: Arvid Heise <[email protected]> AuthorDate: Thu Feb 25 13:48:52 2021 +0100 [hotfix][core] Recovered IteratorSourceReader correctly checks splits on start. Currently, start checks the iterator which is always null before polling. This violates the invariant in notifyNoMoreSplits. --- .../flink/api/connector/source/lib/util/IteratorSourceReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReader.java b/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReader.java index 52d31ac..5c9ae25 100644 --- a/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReader.java +++ b/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReader.java @@ -84,7 +84,7 @@ public class IteratorSourceReader< @Override public void start() { // request a split only if we did not get one during restore - if (iterator == null) { + if (remainingSplits == null) { context.sendSplitRequest(); } }
