[jira] [Created] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[Shang Yuanchun (Jira)]

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)