Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r165102131
--- 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 --
Why can't it remain a `Collection`?
---
