From 05a8a2c80e3721a394f175dd032ebda331cd61b3 Mon Sep 17 00:00:00 2001 From: Grigoriy Rozhkov Date: Fri, 12 Aug 2016 16:17:32 +0300 Subject: [PATCH] copying oozie.warden to prevent failure copying oozie.warden.conf should prevent possible issues with packages installation. Related bug: 1607704 Change-Id: I33e8f19037f61c1cbd310d7d703383083715f658 --- sahara/plugins/mapr/domain/node_process.py | 2 ++ sahara/plugins/mapr/services/oozie/oozie.py | 8 ++++++++ 2 files changed, 10 insertions(+) diff --git a/sahara/plugins/mapr/domain/node_process.py b/sahara/plugins/mapr/domain/node_process.py index 264d8e2..fd2e267 100644 --- a/sahara/plugins/mapr/domain/node_process.py +++ b/sahara/plugins/mapr/domain/node_process.py @@ -59,6 +59,8 @@ class NodeProcess(object): self.execute_action(instances, Action.STOP) def execute_action(self, instances, action): + if len(instances) == 0: + return nodes = ','.join(map(lambda i: i.internal_ip, instances)) args = {'service': self.name, 'action': action.name, 'nodes': nodes} command = WARDEN_MANAGED_CMD % args diff --git a/sahara/plugins/mapr/services/oozie/oozie.py b/sahara/plugins/mapr/services/oozie/oozie.py index a387295..5e3d0b3 100644 --- a/sahara/plugins/mapr/services/oozie/oozie.py +++ b/sahara/plugins/mapr/services/oozie/oozie.py @@ -91,6 +91,14 @@ class Oozie(s.Service): def post_configure(self, cluster_context, instances): super(Oozie, self).install(cluster_context, instances) + oozie_instances = cluster_context.filter_instances(instances, + service=self) + for instance in oozie_instances: + with instance.remote() as r: + r.execute_command( + 'sudo cp ' + '/opt/mapr/oozie/oozie-%s/conf/warden.oozie.conf ' + '/opt/mapr/conf/conf.d' % self.version) def post_install(self, cluster_context, instances): oozie_inst = cluster_context.get_instance(OOZIE)