You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/01/05 14:42:42 UTC
[2/5] flink git commit: [FLINK-5323] [docs] Replace
CheckpointNotifier with CheckpointListener
[FLINK-5323] [docs] Replace CheckpointNotifier with CheckpointListener
THis closes #3006.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb46fffe
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb46fffe
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bb46fffe
Branch: refs/heads/release-1.2
Commit: bb46fffe310f9cd6f667293df14d98e90011d591
Parents: 335175e
Author: Abhishek R. Singh <ab...@tetrationanalytics.com>
Authored: Wed Dec 14 06:05:11 2016 -0800
Committer: zentol <ch...@apache.org>
Committed: Thu Jan 5 14:00:56 2017 +0100
----------------------------------------------------------------------
docs/dev/state.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/bb46fffe/docs/dev/state.md
----------------------------------------------------------------------
diff --git a/docs/dev/state.md b/docs/dev/state.md
index a772a03..99f9055 100644
--- a/docs/dev/state.md
+++ b/docs/dev/state.md
@@ -241,7 +241,7 @@ Instance fields can be checkpointed by using the `Checkpointed` interface.
When the user-defined function implements the `Checkpointed` interface, the `snapshotState(\u2026)` and `restoreState(\u2026)`
methods will be executed to draw and restore function state.
-In addition to that, user functions can also implement the `CheckpointNotifier` interface to receive notifications on
+In addition to that, user functions can also implement the `CheckpointListener` interface to receive notifications on
completed checkpoints via the `notifyCheckpointComplete(long checkpointId)` method.
Note that there is no guarantee for the user function to receive a notification if a failure happens between
checkpoint completion and notification. The notifications should hence be treated in a way that notifications from
@@ -346,7 +346,7 @@ public static class CounterSource
}
{% endhighlight %}
-Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `flink.streaming.api.checkpoint.CheckpointNotifier` interface.
+Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `org.apache.flink.runtime.state.CheckpointListener` interface.
## State Checkpoints in Iterative Jobs