[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324657#comment-17324657 ]
Zhilong Hong commented on FLINK-22326: -------------------------------------- Hi, [~qqibrow], JIRA is mainly used for issue reporting and improvement proposing. Once you got any question during the usage of Flink, please feel free to send emails to u...@flink.apache.org, as illustrated in https://flink.apache.org/community.html. By the way, would you mind check the log of JobManager and attach the part where exceptions related to checkpoints happens? > 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 > Priority: Major > 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 > !Screen Shot 2021-04-16 at 12.43.38 PM.png! > > but always fail on checkpoint in 1.11 > !Screen Shot 2021-04-16 at 12.40.34 PM.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)