GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3340
[FLINK-5703][runtime]Job manager failure recovery via reconciliation with
TaskManager reports
This is part of [Non-disruptive JobManager Failures via Reconciliation
](https://issues.apache.org/jira/browse/FLINK-4911).
The design doc for this part is attached in the JIRA and it mainly contains
the following work:
- **RECONCILING** state transition for job status and execution.
- The data structure recovery for **ExecutionGraph**,
**ExecutionVertex**,**Execution** based on **TaskManager** reports.
Two parts are left for the whole feature:
- The related modifications in **TaskManger** side will be submitted in
another JIRA, including not cancel the tasks when notified job leader changed
and report the task status to **JobManager**, etc.
- This PR will not make an effect on the current master branch, so it is
safe to merge. The reconcile logic should be triggered by **JobManagerRunner**
when grants leadership, but it is dependent on [Determine whether the job
starts from last JobManager
failure](https://issues.apache.org/jira/browse/FLINK-5501) , so I will modify
the **JobManagerRunner** logic after
[FLINK-5501](https://issues.apache.org/jira/browse/FLINK-5501) is merged.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wangzhijiang999/flink FLINK-5703
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3340.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3340
----
commit 7337754bd8d12808a328b55e184b0fe59cf6e11d
Author: æ·æ± <[email protected]>
Date: 2017-02-17T08:41:44Z
[FLINK-5703][runtime]Job manager failure recovery based on reconciliation
with TaskManager reports
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
