Repository: hadoop Updated Branches: refs/heads/branch-2 c664062fb -> ca575e6ad
MAPREDUCE-6574. MR AM should print host of failed tasks. (Mohammad Shahid Khan via wangda) (cherry picked from commit 32b3dc11eba8f2d8f22ca502bf30d6aa8839460e) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/ca575e6a Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/ca575e6a Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/ca575e6a Branch: refs/heads/branch-2 Commit: ca575e6addb801accafa7e3a6dad08d75cf79bdc Parents: c664062 Author: Wangda Tan <[email protected]> Authored: Mon Dec 28 11:03:23 2015 -0800 Committer: Wangda Tan <[email protected]> Committed: Mon Dec 28 11:04:30 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/ca575e6a/hadoop-mapreduce-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 061d8a4..cac9a77 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -157,6 +157,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/ca575e6a/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();
