diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 838df71d3f..b55fa0d9ff 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 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 a5321415ad..8fff7de5a1 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 void handle(TaskAttemptEvent event) { 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();