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 2009/10/18 11:40:58 UTC
svn commit: r826387 - in /hadoop/mapreduce/branches/branch-0.21: CHANGES.txt
src/java/org/apache/hadoop/mapred/JobTracker.java
Author: cdouglas
Date: Sun Oct 18 09:40:57 2009
New Revision: 826387
URL: http://svn.apache.org/viewvc?rev=826387&view=rev
Log:
MAPREDUCE-1104. Initialize RecoveryManager in JobTracker cstr called by Mumak.
Contributed by Hong Tang
Modified:
hadoop/mapreduce/branches/branch-0.21/CHANGES.txt
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java
Modified: hadoop/mapreduce/branches/branch-0.21/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/CHANGES.txt?rev=826387&r1=826386&r2=826387&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/CHANGES.txt (original)
+++ hadoop/mapreduce/branches/branch-0.21/CHANGES.txt Sun Oct 18 09:40:57 2009
@@ -750,3 +750,5 @@
MAPREDUCE-1117. Fix ClusterMetrics to return info about slots instead of
tasks. (Amareshwari Sriramadasu via sharad)
+ MAPREDUCE-1104. Initialize RecoveryManager in JobTracker cstr called by
+ Mumak. (Hong Tang via cdouglas)
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=826387&r1=826386&r2=826387&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java Sun Oct 18 09:40:57 2009
@@ -157,7 +157,7 @@
static final Clock DEFAULT_CLOCK = new Clock();
- private JobHistory jobHistory = null;
+ private final JobHistory jobHistory;
/**
* A client tried to submit a job before the Job Tracker was ready.
@@ -1125,12 +1125,12 @@
////////////////////////////////////////////////////////////////
int port;
String localMachine;
- private String trackerIdentifier;
+ private final String trackerIdentifier;
long startTime;
int totalSubmissions = 0;
private int totalMapTaskCapacity;
private int totalReduceTaskCapacity;
- private HostsFileReader hostsReader;
+ private final HostsFileReader hostsReader;
// JobTracker recovery variables
private volatile boolean hasRecovered = false;
@@ -1218,9 +1218,9 @@
Thread expireLaunchingTaskThread = new Thread(expireLaunchingTasks,
"expireLaunchingTasks");
- CompletedJobStatusStore completedJobStatusStore = null;
+ final CompletedJobStatusStore completedJobStatusStore;
Thread completedJobsStoreThread = null;
- RecoveryManager recoveryManager;
+ final RecoveryManager recoveryManager;
/**
* It might seem like a bug to maintain a TreeSet of tasktracker objects,
@@ -1266,7 +1266,7 @@
long memSizeForMapSlotOnJT;
long memSizeForReduceSlotOnJT;
- private QueueManager queueManager;
+ private final QueueManager queueManager;
JobTracker(JobConf conf)
throws IOException,InterruptedException, LoginException {
@@ -4183,6 +4183,9 @@
}
myInstrumentation = tmp;
+ // start the recovery manager
+ recoveryManager = new RecoveryManager();
+
this.dnsToSwitchMapping = ReflectionUtils.newInstance(
conf.getClass("topology.node.switch.mapping.impl", ScriptBasedMapping.class,
DNSToSwitchMapping.class), conf);