You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/04/17 17:40:41 UTC
[jira] [Created] (FLINK-6315) Notify on checkpoint timeout
Seth Wiesman created FLINK-6315:
-----------------------------------
Summary: Notify on checkpoint timeout
Key: FLINK-6315
URL: https://issues.apache.org/jira/browse/FLINK-6315
Project: Flink
Issue Type: New Feature
Components: Core
Reporter: Seth Wiesman
Assignee: Seth Wiesman
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 timesout a checkpoint
{code:java}
/**
* This interface must be implemented by functions/operations that want to receive
* a notification if a checkpoint has been {@link org.apache.flink.runtime.checkpoint.CheckpointCoordinator}
*/
public interface CheckpointTimeoutListener {
/**
* This method is called as a notification if a distributed checkpoint has been timed out.
*
* @param checkpointId The ID of the checkpoint that has been timed out.
* @throws Exception
*/
void notifyCheckpointTimeout(long checkpointId) throws Exception;
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)