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 <wan...@apache.org> Authored: Mon Dec 28 11:03:23 2015 -0800 Committer: Wangda Tan <wan...@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();
