hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r747675 - in /hadoop/core/trunk: CHANGES.txt src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Date Wed, 25 Feb 2009 06:11:07 GMT
Author: ddas
Date: Wed Feb 25 06:11:06 2009
New Revision: 747675

URL: http://svn.apache.org/viewvc?rev=747675&view=rev
Log:
HADOOP-5264. Removes redundant configuration object from the TaskTracker. Contributed by Sharad
Agarwal.

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=747675&r1=747674&r2=747675&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Wed Feb 25 06:11:06 2009
@@ -134,6 +134,9 @@
     HADOOP-5042. Add a cleanup stage to log rollover in Chukwa appender.
     (Jerome Boulon via cdouglas)
 
+    HADOOP-5264. Removes redundant configuration object from the TaskTracker.
+    (Sharad Agarwal via ddas)
+
   OPTIMIZATIONS
 
   BUG FIXES

Modified: hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java?rev=747675&r1=747674&r2=747675&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java Wed Feb 25 06:11:06
2009
@@ -185,7 +185,6 @@
   private static final String JOBCACHE = "jobcache";
   private static final String PID = "pid";
   private static final String OUTPUT = "output";
-  private JobConf originalConf;
   private JobConf fConf;
   private int maxCurrentMapTasks;
   private int maxCurrentReduceTasks;
@@ -488,7 +487,6 @@
    */
   synchronized void initialize() throws IOException {
     // use configured nameserver & interface to get local hostname
-    this.fConf = new JobConf(originalConf);
     if (fConf.get("slave.host.name") != null) {
       this.localHostname = fConf.get("slave.host.name");
     }
@@ -961,7 +959,7 @@
    * Start with the local machine name, and the default JobTracker
    */
   public TaskTracker(JobConf conf) throws IOException {
-    originalConf = conf;
+    fConf = conf;
     maxCurrentMapTasks = conf.getInt(
                   "mapred.tasktracker.map.tasks.maximum", 2);
     maxCurrentReduceTasks = conf.getInt(



Mime
View raw message