Ted Yu created FLINK-2866: ----------------------------- Summary: Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle Key: FLINK-2866 URL: https://issues.apache.org/jira/browse/FLINK-2866 Project: Flink Issue Type: Bug Reporter: Ted Yu
Here is related code: {code} public T getState(ClassLoader classLoader) throws Exception { FSDataInputStream inStream = getFileSystem().open(getFilePath()); ObjectInputStream ois = new InstantiationUtil.ClassLoaderObjectInputStream(inStream, classLoader); return (T) ois.readObject(); {code} ObjectInputStream should be closed upon exit from the method -- This message was sent by Atlassian JIRA (v6.3.4#6332)