Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5723
---
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/5723#discussion_r175729909
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
---
@@ -279,15 +279,14 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5723#discussion_r175705138
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
---
@@ -279,15 +279,14 @@
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5723
[FLINK-9019] Unclosed closeableRegistry in
StreamTaskStateInitializerImpl#rawOperatorStateInputs
## What is the purpose of the change
*This pull request fixed a resource(CloseableRegistry)
