You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by as...@apache.org on 2015/12/30 07:56:44 UTC
[19/27] hadoop git commit: MAPREDUCE-6574. MR AM should print host of
failed tasks. (Mohammad Shahid Khan via wangda)
MAPREDUCE-6574. MR AM should print host of failed tasks. (Mohammad Shahid Khan via wangda)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/32b3dc11
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/32b3dc11
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/32b3dc11
Branch: refs/heads/yarn-2877
Commit: 32b3dc11eba8f2d8f22ca502bf30d6aa8839460e
Parents: 993311e
Author: Wangda Tan <wa...@apache.org>
Authored: Mon Dec 28 11:03:23 2015 -0800
Committer: Wangda Tan <wa...@apache.org>
Committed: Mon Dec 28 11:03:23 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/32b3dc11/hadoop-mapreduce-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index 838df71..b55fa0d 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -454,6 +454,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/32b3dc11/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 a532141..8fff7de 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
@@ -1198,9 +1198,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();