[hotfix][core] Make the example for checkpointed SourceFunction a bit…

… less strange.
bbejeck · Sep 7, 2021 · 650cfcf · 650cfcf
1 parent 0128976
commit 650cfcf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ng-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/...ng-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
@@ -75,7 +75,7 @@
  *
  * if (context.isRestored()) {
  * for (Long count : this.checkpointedCount.get()) {
- * this.count = count;
+ * this.count += count;
  * }
  * }
  * }