You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2007/08/28 22:14:34 UTC
svn commit: r570559 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/TaskTracker.java
Author: cutting
Date: Tue Aug 28 13:14:33 2007
New Revision: 570559
URL: http://svn.apache.org/viewvc?rev=570559&view=rev
Log:
HADOOP-1790. Fix tasktracker to work correctly on multi-homed boxes. Contributed by Torsten Curdt.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=570559&r1=570558&r2=570559&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Aug 28 13:14:33 2007
@@ -113,6 +113,9 @@
HADOOP-1740. Fix null pointer exception in sorting map outputs. (Devaraj
Das via omalley)
+ HADOOP-1790. Fix tasktracker to work correctly on multi-homed
+ boxes. (Torsten Curdt via cutting)
+
Release 0.14.0 - 2007-08-17
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=570559&r1=570558&r2=570559&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 Aug 28 13:14:33 2007
@@ -17,13 +17,9 @@
*/
package org.apache.hadoop.mapred;
-import java.io.BufferedInputStream;
-import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
-import java.io.FilterOutputStream;
import java.io.IOException;
-import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.BindException;
@@ -1771,13 +1767,16 @@
JobConf defaultConf = new JobConf();
int port = Integer.parseInt(args[0]);
+ InetSocketAddress address = new InetSocketAddress
+ (defaultConf.get("mapred.task.tracker.report.bindAddress","0.0.0.0"),
+ port);
String taskid = args[1];
//set a very high idle timeout so that the connection is never closed
defaultConf.setInt("ipc.client.connection.maxidletime", 60*60*1000);
TaskUmbilicalProtocol umbilical =
(TaskUmbilicalProtocol)RPC.getProxy(TaskUmbilicalProtocol.class,
TaskUmbilicalProtocol.versionID,
- new InetSocketAddress(port),
+ address,
defaultConf);
Task task = umbilical.getTask(taskid);