Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r165282440
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
---
@@ -325,8 +325,7 @@ public OperatorStateHandle performOperation() throws
Exception {
return task;
}
- @Override
- public void restore(Collection<OperatorStateHandle> restoreSnapshots)
throws Exception {
+ public void restore(StateObjectCollection<OperatorStateHandle>
restoreSnapshots) throws Exception {
--- End diff --
I couldn't find any call sites of these methods in the implementations of
`Snapshotable#restore`. But I only skimmed over it.
---
