GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5701
8703 c savepoint
Based on #5690 and #5699.
## What is the purpose of the change
With this PR accumulator updates are sent via heartbeats from the
TaskManager to JobManagers.
The SavepointMigrationTestBase was also ported to flip6, serving as
preliminary verification until the other accumulator tests are ported.
## Verifying this change
*(Please pick either of the following options)*
This change added tests and can be verified as follows:
* run SavepointMigrationTestBase
## 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: (no)
- The runtime per-record code paths (performance sensitive): (no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (no)
- If yes, how is the feature documented? (not applicable)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 8703_c_savepoint
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5701.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 #5701
----
commit 14bcb66d858ee3e9488a51df7bfa1e36ec97f463
Author: zentol <chesnay@...>
Date: 2018-03-14T13:21:27Z
[FLINK-8942][runtime] Pass heartbeat target ResourceID
commit 761fd90f07335883429fc80fb4032b9ef28d32f5
Author: zentol <chesnay@...>
Date: 2018-03-14T17:52:16Z
[FLINK-8881][runtime] Send accumulator updates via heartbeats
commit 280874939c4d77e893da80e1e40acdcc869280bb
Author: zentol <chesnay@...>
Date: 2018-03-07T10:05:42Z
[FLINK-8935][tests] Implement MiniClusterClient#getAccumulators
commit d2fa754d9c5b68672ddc16233cdf390dabfd17c0
Author: zentol <chesnay@...>
Date: 2018-03-06T12:26:59Z
[FLINK-8935][tests] Implement MiniClusterClient#triggerSavepoint
commit ea04fd437d305a76c74edc6aa6c473a1fa917895
Author: zentol <chesnay@...>
Date: 2018-02-26T13:54:07Z
[FLINK-8703][tests] Port SavepointMigrationTestBase to MiniClusterResource
----
---
