diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/LogCLIHelpers.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/LogCLIHelpers.java index 3ea3fa6..eb43568 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/LogCLIHelpers.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/LogCLIHelpers.java @@ -595,6 +595,8 @@ public void printContainersList(ContainerLogsRequest options, } catch (AccessControlException | AccessDeniedException ace) { logDirNoAccessPermission(remoteAppLogDir.toString(), appOwner, ace.getMessage()); + } catch (IOException ioe) { + logDirIOError(remoteAppLogDir.toString(), ioe.getMessage()); } return nodeFiles; } @@ -644,6 +646,11 @@ private static void logDirNoAccessPermission(String remoteAppLogDir, + ". Error message found: " + errorMessage); } + private static void logDirIOError(String remoteAppLogDir, String errMsg) { + System.err.println("Cannot access to " + remoteAppLogDir + + ". Error message found: " + errMsg); + } + @Private public PrintStream createPrintStream(String localDir, String nodeId, String containerId) throws IOException {