openstack/deb-sahara
Code Issues Proposed changes

Change zk_instance to zk_instances in storm plugin

Browse Source 
get_instances will return a list, so we use zk_instances instead
of zk_instance. We remove the "if" check for method
_start_zookeeper_processes already checks zk_instances.

Change-Id: Iac48dcad3439871ab3bc8479bed715fe14625c1d
This commit is contained in:
Ken Chen 2015-07-23 11:11:42 +08:00
parent f0e681426a
commit 5a62575049
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): def start_cluster(self, cluster):
sm_instance = utils.get_instance(cluster, "nimbus") sm_instance = utils.get_instance(cluster, "nimbus")
sl_instances = utils.get_instances(cluster, "supervisor") sl_instances = utils.get_instances(cluster, "supervisor")
zk_instance = utils.get_instances(cluster, "zookeeper") zk_instances = utils.get_instances(cluster, "zookeeper")
if zk_instance: # start zookeeper processes
self._start_zookeeper_processes(zk_instance) self._start_zookeeper_processes(zk_instances)
# start storm master # start storm master
if sm_instance: if sm_instance: