openstack/deb-sahara
Code Issues Proposed changes

Merge "Change zk_instance to zk_instances in storm plugin"

Browse Source
This commit is contained in:
Jenkins 2015-07-27 12:07:03 +00:00 committed by Gerrit Code Review
commit e0d1552e35
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sahara/plugins/storm/plugin.py
View File

@ -86,10 +86,10 @@ class StormProvider(p.ProvisioningPluginBase):
def start_cluster(self, cluster):
sm_instance = utils.get_instance(cluster, "nimbus")
sl_instances = utils.get_instances(cluster, "supervisor")
zk_instance = utils.get_instances(cluster, "zookeeper")
zk_instances = utils.get_instances(cluster, "zookeeper")
if zk_instance:
self._start_zookeeper_processes(zk_instance)
# start zookeeper processes
self._start_zookeeper_processes(zk_instances)
# start storm master
if sm_instance: