svn commit: r417574 - in /lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred: TaskTracker.java TaskTrackerStatus.java

[cu...@apache.org]

Author: cutting
Date: Tue Jun 27 12:55:39 2006
New Revision: 417574

URL: http://svn.apache.org/viewvc?rev=417574&view=rev
Log:
HADOOP-326.  Remove some dead code.  Contributed by Owen.

Modified:
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java?rev=417574&r1=417573&r2=417574&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java Tue Jun 27 12:55:39 2006
@@ -51,7 +51,6 @@
     InetSocketAddress jobTrackAddr;
 
     int taskReportPort;
-    int mapOutputPort;
 
     Server taskReportServer = null;
     Server mapOutputServer = null;
@@ -123,7 +122,6 @@
 
         // port numbers
         this.taskReportPort = this.fConf.getInt("mapred.task.tracker.report.port", 50050);
-        this.mapOutputPort = this.fConf.getInt("mapred.task.tracker.output.port", 50040);
 
         // RPC initialization
         while (true) {
@@ -320,7 +318,7 @@
             
             TaskTrackerStatus status = 
               new TaskTrackerStatus(taskTrackerName, localHostname, 
-                                    mapOutputPort, httpPort, taskReports, 
+                                    httpPort, taskReports, 
                                     failures); 
             int resultCode = jobClient.emitHeartbeat(status, justStarted);
             justStarted = false;

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java?rev=417574&r1=417573&r2=417574&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java Tue Jun 27 12:55:39 2006
@@ -40,7 +40,6 @@
 
     String trackerName;
     String host;
-    int port;
     int httpPort;
     int failures;
     Vector taskReports;
@@ -54,11 +53,10 @@
 
     /**
      */
-    public TaskTrackerStatus(String trackerName, String host, int port, 
+    public TaskTrackerStatus(String trackerName, String host, 
                              int httpPort, Vector taskReports, int failures) {
         this.trackerName = trackerName;
         this.host = host;
-        this.port = port;
         this.httpPort = httpPort;
 
         this.taskReports = new Vector();
@@ -76,11 +74,6 @@
     public String getHost() {
         return host;
     }
-    /**
-     */
-    public int getPort() {
-        return port;
-    }
 
     /**
      * Get the port that this task tracker is serving http requests on.
@@ -156,7 +149,6 @@
     public void write(DataOutput out) throws IOException {
         UTF8.writeString(out, trackerName);
         UTF8.writeString(out, host);
-        out.writeInt(port);
         out.writeInt(httpPort);
 
         out.writeInt(taskReports.size());
@@ -171,7 +163,6 @@
     public void readFields(DataInput in) throws IOException {
         this.trackerName = UTF8.readString(in);
         this.host = UTF8.readString(in);
-        this.port = in.readInt();
         this.httpPort = in.readInt();
 
         taskReports = new Vector();