MAPREDUCE-2451. Log the details from health check script at the
JobTracker. Contributed by Thomas Graves
git-svn-id: https://svn.apache.org/repos/asf/hadoop/mapreduce/trunk@1101314 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt
index 39c8ca7..98c0038 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -164,6 +164,9 @@
MAPREDUCE-2460. Fix flaky test TestFairSchedulerSystem. (todd)
+ MAPREDUCE-2451. Log the details from health check script at the
+ JobTracker. (Thomas Graves via cdouglas)
+
Release 0.22.0 - Unreleased
INCOMPATIBLE CHANGES
diff --git a/src/java/org/apache/hadoop/mapred/JobTracker.java b/src/java/org/apache/hadoop/mapred/JobTracker.java
index b6496bb..ad6ef13 100644
--- a/src/java/org/apache/hadoop/mapred/JobTracker.java
+++ b/src/java/org/apache/hadoop/mapred/JobTracker.java
@@ -731,16 +731,19 @@
if (blackListed) {
if (LOG.isDebugEnabled()) {
LOG.debug("Adding blacklisted reason for tracker : " + hostName
- + " Reason for blacklisting is : " + rfb);
+ + " Reason for blacklisting is : " + rfb
+ + " Reason details : " + reason);
}
if (!fi.getReasonforblacklisting().contains(rfb)) {
LOG.info("Adding blacklisted reason for tracker : " + hostName
- + " Reason for blacklisting is : " + rfb);
+ + " Reason for blacklisting is : " + rfb
+ + " Reason details : " + reason);
}
fi.addBlackListedReason(rfb, reason);
} else {
LOG.info("Blacklisting tracker : " + hostName
- + " Reason for blacklisting is : " + rfb);
+ + " Reason for blacklisting is : " + rfb
+ + " Reason details : " + reason);
Set<TaskTracker> trackers =
hostnameToTaskTracker.get(hostName);
synchronized (trackers) {
