[jira] [Created] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

[Shang Yuanchun (Jira)]

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)