openstack/deb-sahara
Code Issues Proposed changes

Fixed RM HA in MapR plugin 5.0.0 MRv2

Browse Source 
Change-Id: I856b9b05997bd8caa3752fdf7c3c13e0b5187755
Closes-bug: #1494294
This commit is contained in:
Artem Osadchyi 2015-09-10 15:14:51 +03:00
parent f7ddd0c94a
commit 8fa1015470
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
sahara/plugins/mapr/versions/v5_0_0_mrv2/context.py
View File

@ -25,7 +25,7 @@ class Context(bc.BaseClusterContext):
self._hadoop_conf = None
self._cluster_mode = yarn.YARNv270.cluster_mode
self._node_aware = True
self._resource_manager_uri = None
self._resource_manager_uri = "maprfs:///"
self._mapr_version = "5.0.0"
self._ubuntu_ecosystem_repo = (
"http://package.mapr.com/releases/ecosystem-5.x/ubuntu binary/")
@ -46,20 +46,15 @@ class Context(bc.BaseClusterContext):
@property
def resource_manager_uri(self):
# FIXME(aosadchyi): Wait for RM HA to work properly
if not self._resource_manager_uri:
ip = self.get_instance(yarn.RESOURCE_MANAGER).internal_ip
self._resource_manager_uri = "%s:8032" % ip
return self._resource_manager_uri
@property
def configure_sh(self):
if not self._configure_sh:
f = "%(base)s -RM %(resource_manager)s -HS %(history_server)s"
configure_sh_template = "%(base)s -HS %(history_server)s"
args = {
"base": super(Context, self).configure_sh,
"resource_manager": self.get_resourcemanager_ip(),
"history_server": self.get_historyserver_ip(),
}
self._configure_sh = f % args
self._configure_sh = configure_sh_template % args
return self._configure_sh