(flink) branch master updated: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 93cd9b6ba8f [FLINK-38267][checkpoint] Fix the test timeout for 
UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
93cd9b6ba8f is described below

commit 93cd9b6ba8f9ea0b323d3fc4e7bd39b85f27e6e8
Author: Rui Fan <fan...@apache.org>
AuthorDate: Mon Aug 25 17:53:51 2025 +0200

    [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.
---
 .../UnalignedCheckpointRescaleWithMixedExchangesITCase.java           | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java
index c24f9b5b655..34c3277c4a1 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java
@@ -230,7 +230,7 @@ public class 
UnalignedCheckpointRescaleWithMixedExchangesITCase extends TestLogg
 
         sourceStream1
                 .rebalance()
-                .connect(forwardedStream)
+                .connect(forwardedStream.rebalance())
                 .map(new SleepingCoMap())
                 .name("Co-Map")
                 .setParallelism(getRandomParallelism());
@@ -307,7 +307,7 @@ public class 
UnalignedCheckpointRescaleWithMixedExchangesITCase extends TestLogg
         DataStream<Long> multiInputMap =
                 sourceStream1
                         .rebalance()
-                        .connect(forwardedStream)
+                        .connect(forwardedStream.rebalance())
                         .map(new SleepingCoMap())
                         .name("Co-Map")
                         .setParallelism(getRandomParallelism());