1996fanrui opened a new pull request, #26938:
URL: https://github.com/apache/flink/pull/26938

   ## What is the purpose of the change
   
   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.
   
   See more from 
https://github.com/apache/flink/pull/26935#issuecomment-3220787873
   
   ## Brief change log
   
   [FLINK-38267][checkpoint] Fix the test timeout for 
UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
   
   Explicitly specifying rebalance can avoid the forward exchange.
   
   
   
   ## Verifying this change
   
   - Change 
UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
   - And run it multiple times locally
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to