Skip to content

Commit c2c8d8b

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 f0c6178 commit c2c8d8b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
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());
@@ -307,7 +307,7 @@ private static JobClient createMixedComplexityDAG(StreamExecutionEnvironment env
307307
DataStream<Long> multiInputMap =
308308
sourceStream1
309309
.rebalance()
310-
.connect(forwardedStream)
310+
.connect(forwardedStream.rebalance())
311311
.map(new SleepingCoMap())
312312
.name("Co-Map")
313313
.setParallelism(getRandomParallelism());

0 commit comments

Comments
 (0)