[FLINK-22545][tests] Fix delayed split assignment in OperatorEventSen…

…dingCheckpointITCase
bbejeck · Aug 17, 2021 · d081d9a · d081d9a
1 parent 650d463
commit d081d9a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java b/...org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java
@@ -308,6 +308,10 @@ public Collection<SplitT> snapshotState(long checkpointId) throws Exception {
 
  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();