flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [02/10] flink git commit: [hotfix][docs] update Checkpoint docs with correct code example
Date Sun, 25 Jun 2017 11:50:23 GMT
[hotfix][docs] update Checkpoint docs with correct code example


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

Branch: refs/heads/release-1.3
Commit: b954eda8763dd030b0325e0e001aa930f64ef72f
Parents: c815ada
Author: Nico Kruber <nico@data-artisans.com>
Authored: Wed May 31 10:50:39 2017 +0200
Committer: zentol <chesnay@apache.org>
Committed: Sun Jun 25 08:55:09 2017 +0200

----------------------------------------------------------------------
 .../org/apache/flink/streaming/api/checkpoint/Checkpointed.java    | 2 +-
 .../flink/streaming/api/checkpoint/CheckpointedAsynchronously.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/b954eda8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
index 6de7329..74c5189 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
@@ -41,7 +41,7 @@ import org.apache.flink.annotation.PublicEvolving;
  *     }
  *
  *     public void restoreState(List<Integer> state) throws Exception {
- *         this.value = state.count.isEmpty() ? 0 : state.get(0);
+ *         this.value = state.isEmpty() ? 0 : state.get(0);
  *     }
  *
  *     public T map(T value) {

http://git-wip-us.apache.org/repos/asf/flink/blob/b954eda8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
index b96c242..96edb3a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
@@ -42,7 +42,7 @@ import org.apache.flink.annotation.PublicEvolving;
  *     }
  *
  *     public void restoreState(List<Integer> state) throws Exception {
- *         this.value = state.count.isEmpty() ? 0 : state.get(0);
+ *         this.value = state.isEmpty() ? 0 : state.get(0);
  *     }
  *
  *     public T map(T value) {


Mime
View raw message