Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r165112749
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java
---
@@ -130,7 +136,7 @@ public OperatorStateCheckpointOutputStream
getRawOperatorStateOutput() throws Ex
}
private <T extends StreamStateHandle> void closeAndUnregisterStream(
- NonClosingCheckpointOutputStream<T> stream) throws IOException {
+ NonClosingCheckpointOutputStream<? extends T> stream) throws
IOException {
--- End diff --
Should be sufficient to have `NonClosingCheckpointOutputStream<? extends
StreamStateHandle>`
---
