You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Lu Niu (Jira)" <ji...@apache.org> on 2021/04/16 19:47:00 UTC
[jira] [Created] (FLINK-22326) Job contains Iterate Operator always
fails on Checkpoint
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)