flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sjwiesman <...@git.apache.org>
Subject [GitHub] flink pull request #3729: [FLINK-6315] Notify on checkpoint timeout
Date Mon, 17 Apr 2017 17:54:08 GMT
GitHub user sjwiesman opened a pull request:


    [FLINK-6315] Notify on checkpoint timeout

    A common use case when writing a custom operator that outputs data to some third party
location to partially output on checkpoint and then commit on notifyCheckpointComplete. If
that external system does not gracefully handle rollbacks (such as Amazon S3 not allowing
consistent delete operations) then that data needs to be handled by the next checkpoint.
    The idea is to add a new interface similar to CheckpointListener that provides a callback
when the CheckpointCoordinator times out a checkpoint
    This is required for the eventually consistent sink coming in FLINK-6306 to be able to
differentiate between concurrent checkpoints and timed out checkpoints. 

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/sjwiesman/flink FLINK-6315

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #3729
commit 323851929772b4c57e65b7146e96af6687d3a2eb
Author: Seth Wiesman <swiesman@mediamath.com>
Date:   2017-04-15T21:13:20Z

    FLINK-6315 Notify on checkpoint timeout


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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message