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 ju...@apache.org on 2017/02/06 03:27:06 UTC
hadoop git commit: MAPREDUCE-6338. MR AppMaster does not honor
ephemeral port range. Contributed by Frank Nguyen.
Repository: hadoop
Updated Branches:
refs/heads/trunk 3ea6d3517 -> d401e63b6
MAPREDUCE-6338. MR AppMaster does not honor ephemeral port range. Contributed by Frank Nguyen.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d401e63b
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d401e63b
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d401e63b
Branch: refs/heads/trunk
Commit: d401e63b6c3695d1f8f3f4958b8d592b15342b17
Parents: 3ea6d35
Author: Junping Du <ju...@apache.org>
Authored: Sun Feb 5 19:28:01 2017 -0800
Committer: Junping Du <ju...@apache.org>
Committed: Sun Feb 5 19:28:01 2017 -0800
----------------------------------------------------------------------
.../hadoop/mapred/TaskAttemptListenerImpl.java | 17 ++++++++---------
1 file changed, 8 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/d401e63b/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 2c0ea2b..5669f3e 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
@@ -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,
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org