Skip to content

Commit ec698ee

Browse files
committed
[FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
When one task has multiple inputs, and the unaligned checkpoint will be disabled for all inputs once one input exchange does not support unaligned checkpoint. It caused no inflight buffers, but UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint always wait for checkpoint with inflight buffers. Explicitly specifying rebalance can avoid the forward exchange.
1 parent fe66ea6 commit ec698ee

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ private static JobClient createMultiInputDAG(StreamExecutionEnvironment env) thr
230230

231231
sourceStream1
232232
.rebalance()
233-
.connect(forwardedStream)
233+
.connect(forwardedStream.rebalance())
234234
.map(new SleepingCoMap())
235235
.name("Co-Map")
236236
.setParallelism(getRandomParallelism());

0 commit comments

Comments
 (0)