You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by st...@apache.org on 2018/03/05 13:02:47 UTC
[3/3] incubator-slider git commit: SLIDER-12159 multihoming -preserve
ports
SLIDER-12159 multihoming -preserve ports
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/4286d30c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/4286d30c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/4286d30c
Branch: refs/heads/feature/SLIDER-1259-multihomed
Commit: 4286d30c609ca18b1dedfa8a5588dd53761b91be
Parents: 2ef2bd4
Author: Steve Loughran <st...@apache.org>
Authored: Mon Mar 5 13:01:46 2018 +0000
Committer: Steve Loughran <st...@apache.org>
Committed: Mon Mar 5 13:02:34 2018 +0000
----------------------------------------------------------------------
.../java/org/apache/slider/server/appmaster/SliderAppMaster.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/4286d30c/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
----------------------------------------------------------------------
diff --git a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
index a56c141..b416bed 100644
--- a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
+++ b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
@@ -1685,6 +1685,9 @@ public class SliderAppMaster extends AbstractSliderLaunchedService
YarnConfiguration.NM_ADDRESS,
"0.0.0.0:" + port,
port);
+ // but force in the desired port, irrespective of the value
+ // in the configuration fields.
+ rpcAddress = new InetSocketAddress(rpcAddress.getAddress(), port);
rpcService =
new WorkflowRpcService("SliderRPC",
RpcBinder.createProtobufServer(rpcAddress, getConfig(),