|
@@ -134,15 +134,14 @@ public class TaskAttemptListenerImpl extends CompositeService
|
|
|
protected void startRpcServer() {
|
|
|
Configuration conf = getConfig();
|
|
|
try {
|
|
|
- server =
|
|
|
- new RPC.Builder(conf).setProtocol(TaskUmbilicalProtocol.class)
|
|
|
- .setInstance(this).setBindAddress("0.0.0.0")
|
|
|
- .setPort(0).setNumHandlers(
|
|
|
- conf.getInt(MRJobConfig.MR_AM_TASK_LISTENER_THREAD_COUNT,
|
|
|
- MRJobConfig.DEFAULT_MR_AM_TASK_LISTENER_THREAD_COUNT))
|
|
|
- .setVerbose(false).setSecretManager(jobTokenSecretManager)
|
|
|
- .build();
|
|
|
-
|
|
|
+ server = new RPC.Builder(conf).setProtocol(TaskUmbilicalProtocol.class)
|
|
|
+ .setInstance(this).setBindAddress("0.0.0.0")
|
|
|
+ .setPortRangeConfig(MRJobConfig.MR_AM_JOB_CLIENT_PORT_RANGE)
|
|
|
+ .setNumHandlers(
|
|
|
+ conf.getInt(MRJobConfig.MR_AM_TASK_LISTENER_THREAD_COUNT,
|
|
|
+ MRJobConfig.DEFAULT_MR_AM_TASK_LISTENER_THREAD_COUNT))
|
|
|
+ .setVerbose(false).setSecretManager(jobTokenSecretManager).build();
|
|
|
+
|
|
|
// Enable service authorization?
|
|
|
if (conf.getBoolean(
|
|
|
CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
|