diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java index af168c5..fbc22c2 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java @@ -183,6 +183,7 @@ public Integer call() { // /////////////////////////// Variable expansion // Before the container script gets written out. List newCmds = new ArrayList(command.size()); + LOG.info("Command (before env expansion) to launch container " + containerID + " : " + command); String appIdStr = app.getAppId().toString(); String relativeContainerLogDir = ContainerLaunch .getRelativeContainerLogDir(appIdStr, containerIdStr); @@ -193,7 +194,7 @@ public Integer call() { newCmds.add(expandEnvironment(str, containerLogDir)); } launchContext.setCommands(newCmds); - + LOG.info("Command (after env expansion) to launch container " + containerID + " : " + newCmds); Map environment = launchContext.getEnvironment(); // Make a copy of env to iterate & do variable expansion for (Entry entry : environment.entrySet()) {