Ted Yu created FLINK-2322: ----------------------------- Summary: Unclosed stream may leak resource Key: FLINK-2322 URL: https://issues.apache.org/jira/browse/FLINK-2322 Project: Flink Issue Type: Bug Reporter: Ted Yu
In UdfAnalyzerUtils.java : {code} ClassReader cr = new ClassReader(Thread.currentThread().getContextClassLoader() .getResourceAsStream(internalClassName.replace('.', '/') + ".class")); {code} The stream returned by getResourceAsStream() should be closed upon exit of findMethodNode() In ParameterTool#fromPropertiesFile(): {code} props.load(new FileInputStream(propertiesFile)); {code} The FileInputStream should be closed before returning. -- This message was sent by Atlassian JIRA (v6.3.4#6332)