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 <[email protected]> Authored: Mon Dec 28 11:03:23 2015 -0800 Committer: Wangda Tan <[email protected]> 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();
