hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wan...@apache.org
Subject hadoop git commit: MAPREDUCE-6574. MR AM should print host of failed tasks. (Mohammad Shahid Khan via wangda)
Date Mon, 28 Dec 2015 19:09:52 GMT
Repository: hadoop
Updated Branches:
  refs/heads/branch-2.8 beec7a2ef -> aa85ce73d


MAPREDUCE-6574. MR AM should print host of failed tasks. (Mohammad Shahid Khan via wangda)

(cherry picked from commit 32b3dc11eba8f2d8f22ca502bf30d6aa8839460e)
(cherry picked from commit ca575e6addb801accafa7e3a6dad08d75cf79bdc)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/aa85ce73
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/aa85ce73
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/aa85ce73

Branch: refs/heads/branch-2.8
Commit: aa85ce73de0720b39dfa54ca3547ec1027d8161e
Parents: beec7a2
Author: Wangda Tan <wangda@apache.org>
Authored: Mon Dec 28 11:03:23 2015 -0800
Committer: Wangda Tan <wangda@apache.org>
Committed: Mon Dec 28 11:08:31 2015 -0800

----------------------------------------------------------------------
 hadoop-mapreduce-project/CHANGES.txt                   |  3 +++
 .../mapreduce/v2/app/job/impl/TaskAttemptImpl.java     | 13 ++++++++++---
 2 files changed, 13 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/aa85ce73/hadoop-mapreduce-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index fbc107f..8113cfb 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -145,6 +145,9 @@ Release 2.8.0 - UNRELEASED
     MAPREDUCE-6566. Add retry support to mapreduce CLI tool.
     (Varun Vasudev via xgong)
 
+    MAPREDUCE-6574. MR AM should print host of failed tasks. 
+    (Mohammad Shahid Khan via wangda)
+
   OPTIMIZATIONS
 
     MAPREDUCE-6376. Add avro binary support for jhist files (Ray Chiang via

http://git-wip-us.apache.org/repos/asf/hadoop/blob/aa85ce73/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
index ac3cf57..f6d144b 100755
--- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
+++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
@@ -1214,9 +1214,16 @@ public abstract class TaskAttemptImpl implements
             JobEventType.INTERNAL_ERROR));
       }
       if (oldState != getInternalState()) {
-          LOG.info(attemptId + " TaskAttempt Transitioned from " 
-           + oldState + " to "
-           + getInternalState());
+        if (getInternalState() == TaskAttemptStateInternal.FAILED) {
+          String nodeId = null == this.container ? "Not-assigned"
+              : this.container.getNodeId().toString();
+          LOG.info(attemptId + " transitioned from state " + oldState + " to "
+              + getInternalState() + ", event type is " + event.getType()
+              + " and nodeId=" + nodeId);
+        } else {
+          LOG.info(attemptId + " TaskAttempt Transitioned from " + oldState
+              + " to " + getInternalState());
+        }
       }
     } finally {
       writeLock.unlock();


Mime
View raw message