[ 
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)

Reply via email to