[ 
https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984843#comment-15984843
 ] 

ASF GitHub Bot commented on FLINK-5892:
---------------------------------------

Github user StefanRRichter commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3770#discussion_r113413839
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java ---
    @@ -50,7 +50,14 @@
        /** The ID of the vertex. */
        private final JobVertexID id;
     
    -   private final ArrayList<JobVertexID> idAlternatives = new ArrayList<>();
    +   /** The alternative IDs of the vertex. */
    +   private final ArrayList<OperatorID> idAlternatives = new ArrayList<>();
    --- End diff --
    
    From the comments, this looks incorrect and I would expect a 
`List<JobVertexID>`here


> Recover job state at the granularity of operator
> ------------------------------------------------
>
>                 Key: FLINK-5892
>                 URL: https://issues.apache.org/jira/browse/FLINK-5892
>             Project: Flink
>          Issue Type: New Feature
>          Components: State Backends, Checkpointing
>            Reporter: Guowei Ma
>            Assignee: Guowei Ma
>
> JobGraph has no `Operator` info so `ExecutionGraph` can only recovery at the 
> granularity of task.
> This leads to the result that the operator of the job may not recover the 
> state from a save point even if the save point has the state of operator. 
>  
> https://docs.google.com/document/d/19suTRF0nh7pRgeMnIEIdJ2Fq-CcNVt5_hR3cAoICf7Q/edit#.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to