Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5121#discussion_r157606329 --- 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) { } --- End diff -- These methods should handle checkpointing of the `count` state.
---