Ted Yu created FLINK-6439:
-----------------------------
Summary: Unclosed InputStream in
OperatorSnapshotUtil#readStateHandle()
Key: FLINK-6439
URL: https://issues.apache.org/jira/browse/FLINK-6439
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
{code}
FileInputStream in = new FileInputStream(path);
DataInputStream dis = new DataInputStream(in);
{code}
None of the in / dis is closed upon return from the method.
In writeStateHandle(), OutputStream should be closed in finally block.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
