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)