Lu Niu created FLINK-22326: ------------------------------ Summary: Job contains Iterate Operator always fails on Checkpoint Key: FLINK-22326 URL: https://issues.apache.org/jira/browse/FLINK-22326 Project: Flink Issue Type: Improvement Components: Runtime / Checkpointing Affects Versions: 1.11.1 Reporter: Lu Niu Attachments: Screen Shot 2021-04-16 at 12.40.34 PM.png, Screen Shot 2021-04-16 at 12.43.38 PM.png
Job contains Iterate Operator will always fail on checkpoint. How to reproduce: [https://gist.github.com/qqibrow/f297babadb0bb662ee398b9088870785] this is based on [https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java,] but a few line difference: 1. Make maxWaitTime large enough when create IterativeStream 2. No output back to Itertive Source Result: The same code is able to checkpoint in 1.9.1 !image-2021-04-16-12-45-23-624.png! but always fail on checkpoint in 1.11 !image-2021-04-16-12-41-35-002.png! It seems -- This message was sent by Atlassian Jira (v8.3.4#803005)