[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895720#comment-15895720
]
Wei-Che Wei commented on FLINK-4816:
------------------------------------
Hi [~ram_krish]
How about make the return value in {{restoreLatestCheckpointedState()}} be
checkpoint id and set it in {{ExecutionGraph}} ?
Then, as we call {{fail()}} in {{Execution}}, we could use
{{this.vertex.getExecutionGraph()}} to access {{ExecutionGraph}} and check if
the checkpoint id is null to determine which exception should be thrown. What
do you think?
BTW, if you have no time, I would really like to take care of this task. Thank
you.
> Executions failed from "DEPLOYING" should retain restored checkpoint
> information
> --------------------------------------------------------------------------------
>
> Key: FLINK-4816
> URL: https://issues.apache.org/jira/browse/FLINK-4816
> Project: Flink
> Issue Type: Sub-task
> Components: Distributed Coordination
> Reporter: Stephan Ewen
>
> When an execution fails from state {{DEPLOYING}}, it should wrap the failure
> to better report the failure cause:
> - If no checkpoint was restored, it should wrap the exception in a
> {{DeployTaskException}}
> - If a checkpoint was restored, it should wrap the exception in a
> {{RestoreTaskException}} and record the id of the checkpoint that was
> attempted to be restored.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
