openstack/sahara-plugin-mapr
Code Issues Proposed changes

Merge "Remove UI configuring for Oozie"

Browse Source
This commit is contained in:
Jenkins 2016-03-03 08:50:24 +00:00 committed by Gerrit Code Review
commit dc0a90a1ae
1 changed files with 15 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
sahara/plugins/mapr/services/oozie/oozie.py
View File

@ -12,7 +12,6 @@
# License for the specific language governing permissions and limitations # License for the specific language governing permissions and limitations
# under the License. # under the License.
from oslo_log import log as logging from oslo_log import log as logging
import sahara.plugins.mapr.domain.configuration_file as bcf import sahara.plugins.mapr.domain.configuration_file as bcf
@ -41,6 +40,8 @@ class Oozie(s.Service):
self._cluster_defaults = ['oozie-default.json'] self._cluster_defaults = ['oozie-default.json']
self._validation_rules = [vu.exactly(1, OOZIE)] self._validation_rules = [vu.exactly(1, OOZIE)]
self._ui_info = [('Oozie', OOZIE, 'http://%s:11000/oozie')] self._ui_info = [('Oozie', OOZIE, 'http://%s:11000/oozie')]
self._libext_path = '/opt/mapr/oozie/oozie-%s/oozie-server/lib/' % \
self.version
def get_config_files(self, cluster_context, configs, instance=None): def get_config_files(self, cluster_context, configs, instance=None):
oozie_site = bcf.HadoopXML("oozie-site.xml") oozie_site = bcf.HadoopXML("oozie-site.xml")
@ -75,7 +76,7 @@ class Oozie(s.Service):
} }
return jdbc_uri % jdbc_args return jdbc_uri % jdbc_args
def _set_owner(remote): def _set_owner(self, remote):
remote.execute_command('chown -R mapr:mapr /opt/mapr/oozie', remote.execute_command('chown -R mapr:mapr /opt/mapr/oozie',
run_as_root=True) run_as_root=True)
@ -84,10 +85,9 @@ class Oozie(s.Service):
oozie_service = cluster_context.get_service(OOZIE) oozie_service = cluster_context.get_service(OOZIE)
if oozie_service: if oozie_service:
oozie_version = oozie_service.version symlink_cmd = (
symlink_cmd = ('cp /usr/share/java/mysql-connector-java.jar ' 'cp /usr/share/java/mysql-connector-java.jar %s' %
'/opt/mapr/oozie/oozie-%s' self._libext_path)
'/oozie-server/lib/') % oozie_version
with oozie_inst.remote() as r: with oozie_inst.remote() as r:
LOG.debug('Installing MySQL connector for Oozie') LOG.debug('Installing MySQL connector for Oozie')
r.execute_command(symlink_cmd, run_as_root=True, r.execute_command(symlink_cmd, run_as_root=True,
@ -96,23 +96,22 @@ class Oozie(s.Service):
def post_start(self, cluster_context, instances): def post_start(self, cluster_context, instances):
instances = cluster_context.filter_instances(instances, OOZIE) instances = cluster_context.filter_instances(instances, OOZIE)
self._install_ui(cluster_context, instances) self._rebuild(cluster_context, instances)
@g.remote_command(1) @g.remote_command(1)
def _rebuild_oozie_war(self, remote, cluster_context): def _rebuild_oozie_war(self, remote, cluster_context):
extjs_url = 'http://dev.sencha.com/deploy/ext-2.2.zip' cmd = '%(home)s/bin/oozie-setup.sh -hadoop %(version)s' \
extjs_file = '/tmp/extjs.zip' ' /opt/mapr/hadoop/hadoop-%(version)s'
g.download(remote, extjs_url, extjs_file) args = {'home': self.home_dir(cluster_context),
cmd = '%(home)s/bin/oozie-setup.sh prepare-war -extjs %(ext)s' 'version': cluster_context.hadoop_version}
args = {'home': self.home_dir(cluster_context), 'ext': extjs_file}
remote.execute_command(cmd % args, run_as_root=True) remote.execute_command(cmd % args, run_as_root=True)
def update(self, cluster_context, instances=None): def update(self, cluster_context, instances=None):
instances = instances or cluster_context.get_instances() instances = instances or cluster_context.get_instances()
instances = cluster_context.filter_instances(instances, OOZIE) instances = cluster_context.filter_instances(instances, OOZIE)
self._install_ui(cluster_context, instances) self._rebuild(cluster_context, instances)
def _install_ui(self, cluster_context, instances): def _rebuild(self, cluster_context, instances):
OOZIE.stop(filter(OOZIE.is_started, instances)) OOZIE.stop(filter(OOZIE.is_started, instances))
g.execute_on_instances( g.execute_on_instances(
instances, self._rebuild_oozie_war, cluster_context) instances, self._rebuild_oozie_war, cluster_context)
@ -138,18 +137,5 @@ class OozieV420(Oozie):
super(OozieV420, self).__init__() super(OozieV420, self).__init__()
self._version = '4.2.0' self._version = '4.2.0'
self._dependencies = [('mapr-oozie-internal', self.version)] self._dependencies = [('mapr-oozie-internal', self.version)]
self._libext_path = '/opt/mapr/oozie/oozie-%s/libext/' % \
def post_install(self, cluster_context, instances): self.version
oozie_inst = cluster_context.get_instance(OOZIE)
oozie_service = cluster_context.get_service(OOZIE)
if oozie_service:
oozie_version = oozie_service.version
symlink_cmd = ('cp /usr/share/java/mysql-connector-java.jar '
'/opt/mapr/oozie/oozie-%s'
'/libext') % oozie_version
with oozie_inst.remote() as r:
LOG.debug('Installing MySQL connector for Oozie')
r.execute_command(symlink_cmd, run_as_root=True,
raise_when_error=False)
self._set_owner(r)