MYRIAD-142 Specifying address:port instead of just port causes NumberFormatException if myriad.mapreduce.shuffle.port provided in any config file
Project: http://git-wip-us.apache.org/repos/asf/incubator-myriad/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-myriad/commit/fc4c650a Tree: http://git-wip-us.apache.org/repos/asf/incubator-myriad/tree/fc4c650a Diff: http://git-wip-us.apache.org/repos/asf/incubator-myriad/diff/fc4c650a Branch: refs/heads/master Commit: fc4c650aa9a1cbd7e38f0b45c5deafc6d261b5de Parents: 4472fdc Author: Yuliya Feldman <yfeld...@maprtech.com> Authored: Wed Sep 23 10:03:35 2015 -0700 Committer: Yuliya Feldman <yfeld...@maprtech.com> Committed: Wed Sep 23 10:03:35 2015 -0700 ---------------------------------------------------------------------- .../main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/fc4c650a/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java ---------------------------------------------------------------------- diff --git a/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java b/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java index 0127628..28eb025 100644 --- a/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java +++ b/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/NMExecutorCLGenImpl.java @@ -154,7 +154,7 @@ public class NMExecutorCLGenImpl implements ExecutorCommandLineGenerator { addYarnNodemanagerOpt(KEY_NM_WEBAPP_ADDRESS, ALL_LOCAL_IPV4ADDR + Long.valueOf(ports.getWebAppHttpPort()).toString()); addYarnNodemanagerOpt(KEY_NM_SHUFFLE_PORT, - ALL_LOCAL_IPV4ADDR + Long.valueOf(ports.getShufflePort()).toString()); + Long.valueOf(ports.getShufflePort()).toString()); } protected void appendEnvForNM(StringBuilder cmdLine) {
