Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r159880527 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java --- @@ -147,7 +147,7 @@ public void close() throws IOException { @Override public void dispose() { - IOUtils.closeQuietly(this); + IOUtils.closeQuietly(closeStreamOnCancelRegistry); --- End diff -- Another irrelevant change?
---