You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2021/09/09 15:43:52 UTC
[flink] 07/08: [hotfix][core] Make the example for checkpointed
SourceFunction a bit less strange.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9a26fe9c4e325a9c44bdcc9be3c99aef0a8e1e34
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;
* }
* }
* }