Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-1608. LinuxContainerExecutor has a few DEBUG messages at INFO level (kasha) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1558874 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Karthik Kambatla 2014-01-16 18:42:25 +00:00
parent e05ff82bd9
commit 752441434c
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -343,6 +343,9 @@ Release 2.4.0 - UNRELEASED
YARN-1351. Invalid string format in Fair Scheduler log warn message YARN-1351. Invalid string format in Fair Scheduler log warn message
(Konstantin Weitz via Sandy Ryza) (Konstantin Weitz via Sandy Ryza)
YARN-1608. LinuxContainerExecutor has a few DEBUG messages at INFO level
(kasha)
Release 2.3.0 - UNRELEASED Release 2.3.0 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/LinuxContainerExecutor.java
View File

@ -217,8 +217,6 @@ public class LinuxContainerExecutor extends ContainerExecutor {
} }
String[] commandArray = command.toArray(new String[command.size()]); String[] commandArray = command.toArray(new String[command.size()]);
ShellCommandExecutor shExec = new ShellCommandExecutor(commandArray); ShellCommandExecutor shExec = new ShellCommandExecutor(commandArray);
// TODO: DEBUG
LOG.info("initApplication: " + Arrays.toString(commandArray));
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("initApplication: " + Arrays.toString(commandArray)); LOG.debug("initApplication: " + Arrays.toString(commandArray));
} }
@ -274,8 +272,9 @@ public class LinuxContainerExecutor extends ContainerExecutor {
String[] commandArray = command.toArray(new String[command.size()]); String[] commandArray = command.toArray(new String[command.size()]);
shExec = new ShellCommandExecutor(commandArray, null, // NM's cwd shExec = new ShellCommandExecutor(commandArray, null, // NM's cwd
container.getLaunchContext().getEnvironment()); // sanitized env container.getLaunchContext().getEnvironment()); // sanitized env
// DEBUG if (LOG.isDebugEnabled()) {
LOG.info("launchContainer: " + Arrays.toString(commandArray)); LOG.debug("launchContainer: " + Arrays.toString(commandArray));
}
shExec.execute(); shExec.execute();
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
logOutput(shExec.getOutput()); logOutput(shExec.getOutput());
@ -374,7 +373,6 @@ public class LinuxContainerExecutor extends ContainerExecutor {
} }
String[] commandArray = command.toArray(new String[command.size()]); String[] commandArray = command.toArray(new String[command.size()]);
ShellCommandExecutor shExec = new ShellCommandExecutor(commandArray); ShellCommandExecutor shExec = new ShellCommandExecutor(commandArray);
LOG.info(" -- DEBUG -- deleteAsUser: " + Arrays.toString(commandArray));
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("deleteAsUser: " + Arrays.toString(commandArray)); LOG.debug("deleteAsUser: " + Arrays.toString(commandArray));
} }