Ted Yu created FLINK-5390:
-----------------------------
Summary: input should be closed in finally block in
YarnFlinkApplicationMasterRunner#loadJobGraph()
Key: FLINK-5390
URL: https://issues.apache.org/jira/browse/FLINK-5390
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
{code}
FileInputStream input = new FileInputStream(fp);
ObjectInputStream obInput = new ObjectInputStream(input);
jg = (JobGraph) obInput.readObject();
input.close();
{code}
If readObject() throws exception, input would be left unclosed.
Similar issue is in AbstractYarnClusterDescriptor#startAppMaster() around line
726.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
