You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by cd...@apache.org on 2011/05/10 07:27:27 UTC
svn commit: r1101314 - in /hadoop/mapreduce/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/JobTracker.java
Author: cdouglas
Date: Tue May 10 05:27:27 2011
New Revision: 1101314
URL: http://svn.apache.org/viewvc?rev=1101314&view=rev
Log:
MAPREDUCE-2451. Log the details from health check script at the
JobTracker. Contributed by Thomas Graves
Modified:
hadoop/mapreduce/trunk/CHANGES.txt
hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=1101314&r1=1101313&r2=1101314&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Tue May 10 05:27:27 2011
@@ -164,6 +164,9 @@ Trunk (unreleased changes)
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
Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=1101314&r1=1101313&r2=1101314&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Tue May 10 05:27:27 2011
@@ -731,16 +731,19 @@ public class JobTracker implements MRCon
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) {