Repository: incubator-slider Updated Branches: refs/heads/develop 05c083d5c -> 5235f3957
SLIDER-606. Agent is not able to communicate with AppMaster under some scenarios Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/5235f395 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/5235f395 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/5235f395 Branch: refs/heads/develop Commit: 5235f3957ce6e1f81878c233618487494fbcae96 Parents: 05c083d Author: Sumit Mohanty <[email protected]> Authored: Sun Nov 2 18:45:35 2014 -0800 Committer: Sumit Mohanty <[email protected]> Committed: Sun Nov 2 18:45:35 2014 -0800 ---------------------------------------------------------------------- slider-agent/src/main/python/agent/Registry.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/5235f395/slider-agent/src/main/python/agent/Registry.py ---------------------------------------------------------------------- diff --git a/slider-agent/src/main/python/agent/Registry.py b/slider-agent/src/main/python/agent/Registry.py index 6d34956..e0bc5da 100644 --- a/slider-agent/src/main/python/agent/Registry.py +++ b/slider-agent/src/main/python/agent/Registry.py @@ -43,12 +43,12 @@ class Registry(object): sliderRegistry = json.loads(data) internalAttr = sliderRegistry["internal"] for internal in internalAttr: - if internal["api"] == "org.apache.slider.agents.secure": + if internal["api"] == "classpath:org.apache.slider.agents.secure": address0 = internal["addresses"][0] amUrl = address0["uri"] amHost = amUrl.split("/")[2].split(":")[0] amSecuredPort = amUrl.split(":")[2].split("/")[0] - if internal["api"] == "org.apache.slider.agents.oneway": + if internal["api"] == "classpath:org.apache.slider.agents.oneway": address0 = internal["addresses"][0] amUnsecureUrl = address0["uri"] amHost = amUnsecureUrl.split("/")[2].split(":")[0]
