[FLINK-2866] Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.0
• Assignee: Zhihong Yu
• Reporter: Ted Yu
• Created: 19/Oct/15 04:05
• Updated: 25/Oct/15 22:12
• Resolved: 25/Oct/15 22:12

Description

Here is related code:

  public T getState(ClassLoader classLoader) throws Exception {
    FSDataInputStream inStream = getFileSystem().open(getFilePath());
    ObjectInputStream ois = new InstantiationUtil.ClassLoaderObjectInputStream(inStream, classLoader);
    return (T) ois.readObject();

ObjectInputStream should be closed upon exit from the method