[FLINK-22326] Job contains Iterate Operator always fails on Checkpoint

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.11.1
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available stale-assigned
• Assignee: Lu Niu
• Reporter: Lu Niu
• Created: 16/Apr/21 19:46
• Updated: 08/Oct/21 11:23

Description

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

 

but always fail on checkpoint in 1.11

Issue Links

• links to: GitHub Pull Request #15962