Author: vinodkv
Date: Thu Feb 27 01:29:28 2014
New Revision: 1572380
URL: http://svn.apache.org/r1572380
Log:
MAPREDUCE-5766. Moved ping messages from TaskAttempts to be at DEBUG level
inside the ApplicationMaster log. Contributed by Jian He.
Modified:
hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java
Modified: hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt?rev=1572380&r1=1572379&r2=1572380&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt Thu Feb 27
01:29:28 2014
@@ -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
Modified:
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java
URL:
http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java?rev=1572380&r1=1572379&r2=1572380&view=diff
==============================================================================
---
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java
(original)
+++
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java
Thu Feb 27 01:29:28 2014
@@ -360,12 +360,13 @@ public class TaskAttemptListenerImpl ext
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 ext
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.
