Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r165103361
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/Snapshotable.java ---
@@ -54,5 +54,5 @@
*
* @param state the old state to restore.
*/
- void restore(Collection<S> state) throws Exception;
+ void restore(R state) throws Exception;
--- End diff --
To me it is not really clear, why you've made this change here? Code wise
it does not seem necessary.
---
