Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r157606375
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -61,9 +61,9 @@
* isRunning = false;
* }
*
- * public Long snapshotState(long checkpointId, long
checkpointTimestamp) { return count; }
+ * public void snapshotState(FunctionSnapshotContext context) { }
*
- * public void restoreState(Long state) { this.count = state; }
+ * public void initializeState(FunctionInitializationContext context)
{ }
--- End diff --
These methods should handle checkpointing of the count state.
---
