Skip to content

Commit e415483

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 e415483

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)