[jira] [Created] (FLINK-8442) Should recovery the input split when an execution failover with FailoverRegion

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-8442) Should recovery the input split when an execution failover with FailoverRegion

Shang Yuanchun (Jira)
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)