1996fanrui commented on PR #26935: URL: https://github.com/apache/flink/pull/26935#issuecomment-3220787873
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=69481&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=9d734c8c-6253-55e6-3bce-47e7cdf68ac4&l=8852 The CI is timed out in 2.1, and after analysis, it only happens for `UnalignedCheckpointRescaleWithMixedExchangesITCase#createMultiInputDAG`. And I am sure it is a test issue instead of production code issue. The reason is : `Co-Map` task has 2 inputs exchanges, one is rebalance, another one : - **is forward when source2Parallelism is equal to the parallelism of `Co-Map`** - is rebalance when source2Parallelism is not equal to the parallelism of `Co-Map` - All of parallelism are generated randomly - Timeout only happens when it is forward, for this case, `Co-Map` task[1] will disable unaligned checkpoint for all inputs, it causes no inflight buffers during checkpoint. But our test expects `waitForCheckpointWithInflightBuffers`. It means FLINK-38267 bug only happens for multiple outputs. For `MultiInput` cases, the unaligned checkpoint is disabled for all exchanges if any exchanges is disallow unaligned checkpoint, so it is not needed to distinguish specific gate. So I'd like to delete `UnalignedCheckpointRescaleWithMixedExchangesITCase#createMultiInputDAG` or introducing an rebalance after forwardedStream to prevent forward exchange for `Co-Map`. cc @gaborgsomogyi [1] https://github.com/apache/flink/blob/831f3ab75ea8e9d6e3e57a3ef9c1bcadee7e87f6/flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java#L275 -- 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
