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?---
