[flink] 03/04: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange.

[sewen]

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;
  *              }
  *          }
  *      }