From 5a62575049a7ff613009167d9a32e670419b8451 Mon Sep 17 00:00:00 2001 From: Ken Chen Date: Thu, 23 Jul 2015 11:11:42 +0800 Subject: [PATCH] Change zk_instance to zk_instances in storm plugin 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 --- sahara/plugins/storm/plugin.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sahara/plugins/storm/plugin.py b/sahara/plugins/storm/plugin.py index 77801daa..adeb9822 100644 --- a/sahara/plugins/storm/plugin.py +++ b/sahara/plugins/storm/plugin.py @@ -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: