This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new d081d9a [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase d081d9a is described below commit d081d9a7b32d5fae74eddcfa3b2d1c1318d3c44b Author: Stephan Ewen <se...@apache.org> AuthorDate: Tue Aug 17 18:23:15 2021 +0200 [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase --- .../operators/coordination/OperatorEventSendingCheckpointITCase.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java b/flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java index beae1b9..3733d43 100644 --- a/flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java @@ -308,6 +308,10 @@ public class OperatorEventSendingCheckpointITCase extends TestLogger { private void fullFillPendingRequests() { for (int subtask : pendingRequests) { + // respond only to requests for which we still have registered readers + if (!context.registeredReaders().containsKey(subtask)) { + continue; + } super.handleSplitRequest(subtask, null); } pendingRequests.clear();