Ted Yu created FLINK-6169: ----------------------------- Summary: yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error Key: FLINK-6169 URL: https://issues.apache.org/jira/browse/FLINK-6169 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
Here is one example: {code} 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); } {code} yarnClient should be stopped when deployment fails. -- This message was sent by Atlassian JIRA (v6.3.15#6346)