GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/4828
[FLINK-4816] [checkpoints] Executions failed from "DEPLOYING" should retain
restored checkpoint information
## What is the purpose of the change
This PR is base on #3478 and added some improvements.
## Brief change log
- Rebased #3478 to the latest master branch.
- Checked if CheckpointCoordinator is exist.
- Added corresponding tests.
## Verifying this change
- Updated tests in `CheckpointCoordinatorTest` and
`ExecutionVertexDeploymentTest`.
- Added a new test in `ExecutionVertexDeploymentTest` for deploying
failed after restoring.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): **no**
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: **no**
- The serializers: **don't know**
- The runtime per-record code paths (performance sensitive): **don't
know**
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: **yes**
## Documentation
- Does this pull request introduce a new feature? **no**
- If yes, how is the feature documented? **not documented**
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tony810430/flink FLINK-4816
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4828.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 #4828
----
commit 5ed707775be9d0b61edf62884e97a7562acfc787
Author: Ramkrishna <[email protected]>
Date: 2017-03-06T11:25:37Z
[FLINK-4816] Executions failed from "DEPLOYING" should retain restored
checkpoint information
commit 03678006a9729bf5339b812e032e57727d6409f6
Author: Ramkrishna <[email protected]>
Date: 2017-03-06T11:41:58Z
Add lock to getRestoredCheckpointID
commit 2ddcc511e3f6716359bb47edba0ed5ad5be0ec5f
Author: Tony Wei <[email protected]>
Date: 2017-10-16T02:21:22Z
check if CheckpointCoordinator is enable, add corresponding unit tests
----
---
