flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [2/6] flink git commit: [hotfix][docs] Remove reference to CheckpointedRestoring
Date Mon, 05 Mar 2018 16:54:41 GMT
[hotfix][docs] Remove reference to CheckpointedRestoring

This closes #5627.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d14cbe97
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d14cbe97
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d14cbe97

Branch: refs/heads/master
Commit: d14cbe97139c3173fa4be0804ea63fdfcaec6a27
Parents: 128127a
Author: Stephen Parente <webmakersteve@gmail.com>
Authored: Fri Mar 2 14:20:10 2018 -0800
Committer: zentol <chesnay@apache.org>
Committed: Mon Mar 5 17:54:28 2018 +0100

----------------------------------------------------------------------
 docs/dev/stream/state/state.md | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/d14cbe97/docs/dev/stream/state/state.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index 3ea9b7a..a26e24d 100644
--- a/docs/dev/stream/state/state.md
+++ b/docs/dev/stream/state/state.md
@@ -386,8 +386,7 @@ public class BufferingSink
 {% highlight scala %}
 class BufferingSink(threshold: Int = 0)
   extends SinkFunction[(String, Int)]
-    with CheckpointedFunction
-    with CheckpointedRestoring[List[(String, Int)]] {
+    with CheckpointedFunction {
 
   @transient
   private var checkpointedState: ListState[(String, Int)] = _
@@ -426,9 +425,6 @@ class BufferingSink(threshold: Int = 0)
     }
   }
 
-  override def restoreState(state: List[(String, Int)]): Unit = {
-    bufferedElements ++= state
-  }
 }
 {% endhighlight %}
 </div>


Mime
View raw message