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)