Repository: incubator-slider Updated Branches: refs/heads/feature/SLIDER-1259-multihomed [created] b8652f042
SLIDER-1259: use NM bind host and address to define what the container should come up as. Issue: how do these get set? That is: will they be in the configs Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/b8652f04 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/b8652f04 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/b8652f04 Branch: refs/heads/feature/SLIDER-1259-multihomed Commit: b8652f0424fda330cc061e53dd34eb16fe97346b Parents: 68b96b7 Author: Steve Loughran <ste...@apache.org> Authored: Wed Feb 14 17:26:34 2018 +0000 Committer: Steve Loughran <ste...@apache.org> Committed: Wed Feb 14 18:51:05 2018 +0000 ---------------------------------------------------------------------- .../org/apache/slider/server/appmaster/SliderAppMaster.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/b8652f04/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 c12fae8..a56c141 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 @@ -1678,7 +1678,13 @@ public class SliderAppMaster extends AbstractSliderLaunchedService protobufRelay); int port = getPortToRequest(); - InetSocketAddress rpcAddress = new InetSocketAddress("0.0.0.0", port); + + // use the same host and address options as the NM + InetSocketAddress rpcAddress = getConfig().getSocketAddr( + YarnConfiguration.NM_BIND_HOST, + YarnConfiguration.NM_ADDRESS, + "0.0.0.0:" + port, + port); rpcService = new WorkflowRpcService("SliderRPC", RpcBinder.createProtobufServer(rpcAddress, getConfig(),