[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-2866. --------------------------------- Resolution: Fixed Assignee: Ted Yu Fix Version/s: 0.10 Fixed via 2d647151c729f707681dd5e2d226e4bbe0329bba > 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 > Assignee: Ted Yu > Fix For: 0.10 > > > 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)