This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit f89d9049947206cd93cb7c4f3b4a9dfc662ba0dc Author: Stephan Ewen <se...@apache.org> AuthorDate: Tue Aug 24 15:37:09 2021 +0200 [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange. --- .../org/apache/flink/streaming/api/functions/source/SourceFunction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java index 0cd513d..766a3ba 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java @@ -75,7 +75,7 @@ import java.io.Serializable; * * if (context.isRestored()) { * for (Long count : this.checkpointedCount.get()) { - * this.count = count; + * this.count += count; * } * } * }