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();