MAPREDUCE-6574. MR AM should print host of failed tasks. (Mohammad Shahid Khan via wangda)
(cherry picked from commit32b3dc11eb
) (cherry picked from commitca575e6add
)
This commit is contained in:
parent
beec7a2efb
commit
aa85ce73de
|
@ -145,6 +145,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
MAPREDUCE-6566. Add retry support to mapreduce CLI tool.
|
MAPREDUCE-6566. Add retry support to mapreduce CLI tool.
|
||||||
(Varun Vasudev via xgong)
|
(Varun Vasudev via xgong)
|
||||||
|
|
||||||
|
MAPREDUCE-6574. MR AM should print host of failed tasks.
|
||||||
|
(Mohammad Shahid Khan via wangda)
|
||||||
|
|
||||||
OPTIMIZATIONS
|
OPTIMIZATIONS
|
||||||
|
|
||||||
MAPREDUCE-6376. Add avro binary support for jhist files (Ray Chiang via
|
MAPREDUCE-6376. Add avro binary support for jhist files (Ray Chiang via
|
||||||
|
|
|
@ -1214,9 +1214,16 @@ public abstract class TaskAttemptImpl implements
|
||||||
JobEventType.INTERNAL_ERROR));
|
JobEventType.INTERNAL_ERROR));
|
||||||
}
|
}
|
||||||
if (oldState != getInternalState()) {
|
if (oldState != getInternalState()) {
|
||||||
LOG.info(attemptId + " TaskAttempt Transitioned from "
|
if (getInternalState() == TaskAttemptStateInternal.FAILED) {
|
||||||
+ oldState + " to "
|
String nodeId = null == this.container ? "Not-assigned"
|
||||||
+ getInternalState());
|
: 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 {
|
} finally {
|
||||||
writeLock.unlock();
|
writeLock.unlock();
|
||||||
|
|
Loading…
Reference in New Issue