Skip to content

Commit c22c3da

Browse files
committed
[FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase
1 parent 70a5657 commit c22c3da

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java

+4
Original file line numberDiff line numberDiff line change
@@ -280,6 +280,10 @@ public Collection<SplitT> snapshotState() throws Exception {
280280

281281
private void fullFillPendingRequests() {
282282
for (int subtask : pendingRequests) {
283+
// respond only to requests for which we still have registered readers
284+
if (!context.registeredReaders().containsKey(subtask)) {
285+
continue;
286+
}
283287
super.handleSplitRequest(subtask, null);
284288
}
285289
pendingRequests.clear();

0 commit comments

Comments
 (0)