Gary Yao created FLINK-13452:
--------------------------------
Summary: Pipelined region failover strategy does not recover Job
if checkpoint cannot be read
Key: FLINK-13452
URL: https://issues.apache.org/jira/browse/FLINK-13452
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.9.0, 1.10.0
Reporter: Gary Yao
Assignee: Gary Yao
Fix For: 1.9.0
Attachments: jobmanager.log
The job does not recover if a checkpoint cannot be read and
{{jobmanager.execution.failover-strategy}} is set to _"region"_.
*Analysis*
The {{RestartCallback}} created by {{AdaptedRestartPipelinedRegionStrategyNG}}
throws a \{{RuntimeException}} if no checkpoints could be read. When the
restart is invoked in a separate thread pool, the exception is swallowed. See:
[https://github.com/apache/flink/blob/21621fbcde534969b748f21e9f8983e3f4e0fb1d/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/AdaptedRestartPipelinedRegionStrategyNG.java#L117-L119]
[https://github.com/apache/flink/blob/21621fbcde534969b748f21e9f8983e3f4e0fb1d/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java#L65]
*Expected behavior*
* Job should restart
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
