shuai.xu created FLINK-8442:
-------------------------------

             Summary: Should recovery the input split when an execution 
failover with FailoverRegion
                 Key: FLINK-8442
                 URL: https://issues.apache.org/jira/browse/FLINK-8442
             Project: Flink
          Issue Type: Bug
          Components: JobManager, Scheduler
    Affects Versions: 1.4.0
            Reporter: shuai.xu


In flip-1, it enable only restart the executions in a FailoverRegion when a 
task fail. But now the input splits are assigned only when an 
ExecutionJobVertex is initializing, so when an executions restarts, the input 
splits it has read may can not be get from job master any more. Need to recover 
the input splits so they can be be consumed again when the task restarts.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to