Repository: hadoop Updated Branches: refs/heads/branch-2 be9b02e0b -> 378d62663
MAPREDUCE-6338. MR AppMaster does not honor ephemeral port range. Contributed by Frank Nguyen. (cherry picked from commit d401e63b6c3695d1f8f3f4958b8d592b15342b17) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/378d6266 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/378d6266 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/378d6266 Branch: refs/heads/branch-2 Commit: 378d62663fc7d1494747c806aa15cc482222ebe4 Parents: be9b02e Author: Junping Du <[email protected]> Authored: Sun Feb 5 19:28:01 2017 -0800 Committer: Junping Du <[email protected]> Committed: Sun Feb 5 19:28:53 2017 -0800 ---------------------------------------------------------------------- .../hadoop/mapred/TaskAttemptListenerImpl.java | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/378d6266/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java index b68d863..fe26ee5 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java @@ -122,15 +122,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, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
