You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by sm...@apache.org on 2014/11/03 03:47:39 UTC
git commit: SLIDER-606. Agent is not able to communicate with
AppMaster under some scenarios
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 <sm...@hortonworks.com>
Authored: Sun Nov 2 18:45:35 2014 -0800
Committer: Sumit Mohanty <sm...@hortonworks.com>
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]