[FLINK-6439] Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Runtime / State Backends
• Assignee: Fang Yong
• Reporter: Ted Yu
• Created: 03/May/17 16:20
• Updated: 19/May/17 22:31
• Resolved: 19/May/17 22:31

Description

    FileInputStream in = new FileInputStream(path);
    DataInputStream dis = new DataInputStream(in);

None of the in / dis is closed upon return from the method.

In writeStateHandle(), OutputStream should be closed in finally block.

Issue Links

• links to: GitHub Pull Request #3819
• links to: GitHub Pull Request #3904