diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index b0d707d038f..74a38756cc5 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -179,6 +179,9 @@ Release 2.4.0 - UNRELEASED MAPREDUCE-5754. Preserve Job diagnostics in history (Gera Shegalov via jlowe) + MAPREDUCE-5766. Moved ping messages from TaskAttempts to be at DEBUG level + inside the ApplicationMaster log. (Jian He via vinodkv) + OPTIMIZATIONS BUG FIXES diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java index 03b6e52db8e..074e3f0fbb8 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java @@ -360,12 +360,13 @@ public class TaskAttemptListenerImpl extends CompositeService if (taskStatus == null) { //We are using statusUpdate only as a simple ping - LOG.info("Ping from " + taskAttemptID.toString()); + if (LOG.isDebugEnabled()) { + LOG.debug("Ping from " + taskAttemptID.toString()); + } return feedback; } // if we are here there is an actual status update to be processed - LOG.info("Status update from " + taskAttemptID.toString()); taskHeartbeatHandler.progressing(yarnAttemptID); TaskAttemptStatus taskAttemptStatus = @@ -453,7 +454,7 @@ public class TaskAttemptListenerImpl extends CompositeService JVMId jvmId = context.jvmId; LOG.info("JVM with ID : " + jvmId + " asked for a task"); - + JvmTask jvmTask = null; // TODO: Is it an authorized container to get a task? Otherwise return null.