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

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Assignee: Roman Maier
• Reporter: Ted Yu
• Created: 24/Dec/16 00:48
• Updated: 06/Jan/17 09:59
• Resolved: 06/Jan/17 09:59

Description

        FileInputStream input = new FileInputStream(fp);
        ObjectInputStream obInput = new ObjectInputStream(input);
        jg = (JobGraph) obInput.readObject();
        input.close();

If readObject() throws exception, input would be left unclosed.

Similar issue is in AbstractYarnClusterDescriptor#startAppMaster() around line 726.

Issue Links

• links to: GitHub Pull Request #3045