[FLINK-5488] yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.2, 1.4.0
• Component/s: Deployment / YARN
• Assignee: Fang Yong
• Reporter: Ted Yu
• Created: 13/Jan/17 21:14
• Updated: 01/Jul/17 10:08
• Resolved: 01/Jul/17 10:08

Description

Here is one example:

    if(jobManagerMemoryMb > maxRes.getMemory() ) {
      failSessionDuringDeployment(yarnClient, yarnApplication);
      throw new YarnDeploymentException("The cluster does not have the requested resources for the JobManager available!\n"
        + "Maximum Memory: " + maxRes.getMemory() + "MB Requested: " + jobManagerMemoryMb + "MB. " + NOTE);
    }

yarnClient implements Closeable.
It should be closed in situations where exception is thrown.

Issue Links

• links to: GitHub Pull Request #3805
• links to: GitHub Pull Request #4022