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)