diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/LogsCLI.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/LogsCLI.java index d62ee5e..424c502 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/LogsCLI.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/LogsCLI.java @@ -535,6 +535,11 @@ private int printAMContainerLogs(Configuration conf, if (amContainerId <= requests.size()) { outputAMContainerLogs(requests.get(amContainerId - 1), conf, logCliHelper); + } else { + System.out.println(String.format( "ERROR: Specified AM containerId" + + " (%s) exceeds the number of AM containers (%s).", + amContainerId, requests.size())); + return -1; } } }