GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3782
[FLINK-6390] [checkpoints] Add API for checkpoints that are triggered via
external systems
Some source systems require to be notified prior to starting a checkpoint,
in order to do preparatory work for the checkpoint.
This PR adds an interface to allow sources to register hooks that are
called by the checkpoint coordinator when triggering / restoring a checkpoint.
These hooks may produce state that is stores with the checkpoint metadata.
Because this changes the checkpoint metadata format, the commit introduces
a new metadata format version.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink trigger_via_source
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3782.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 #3782
----
commit 3332363d50a6a1a78435bacecf3f75cdc54f5bfa
Author: Stephan Ewen <[email protected]>
Date: 2017-03-27T15:20:47Z
[FLINK-6390] [checkpoints] Add API for checkpoints that are triggered via
external systems
This includes
- A interface for hooks that are called by the checkpoint coordinator to
trigger/restore a checkpoint
- A source extension that triggers the operator checkpoints and barrier
injection on certain events
Because this changes the checkpoint metadata format, the commit introduces
a new metadata format version.
----
---
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.
---
