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