Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r165103021
--- 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 --
Ok, if you just talk about this particular usage, I might double-check if
the interface is enough.
---
