|
@@ -2185,8 +2185,6 @@ public class TaskTracker
|
|
int port = Integer.parseInt(args[1]);
|
|
int port = Integer.parseInt(args[1]);
|
|
InetSocketAddress address = new InetSocketAddress(host, port);
|
|
InetSocketAddress address = new InetSocketAddress(host, port);
|
|
TaskAttemptID taskid = TaskAttemptID.forName(args[2]);
|
|
TaskAttemptID taskid = TaskAttemptID.forName(args[2]);
|
|
- //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 umbilical =
|
|
(TaskUmbilicalProtocol)RPC.getProxy(TaskUmbilicalProtocol.class,
|
|
(TaskUmbilicalProtocol)RPC.getProxy(TaskUmbilicalProtocol.class,
|
|
TaskUmbilicalProtocol.versionID,
|
|
TaskUmbilicalProtocol.versionID,
|