From bff7110acfbb4b8accd2c15c3994529cf3965ddf Mon Sep 17 00:00:00 2001 From: "Li, Chen" Date: Mon, 20 Jul 2015 09:11:01 +0800 Subject: [PATCH] Remove cluster status change in HDP plugin The plugins should not be allowed to change status, this is the engine/eventlog job. Change-Id: Ifd1a6ddd4808f16efd9732a8ace27130d7f64f56 --- sahara/plugins/hdp/ambariplugin.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sahara/plugins/hdp/ambariplugin.py b/sahara/plugins/hdp/ambariplugin.py index ef1e85c9..d2fa6133 100644 --- a/sahara/plugins/hdp/ambariplugin.py +++ b/sahara/plugins/hdp/ambariplugin.py @@ -27,7 +27,6 @@ from sahara.plugins.hdp.versions import versionhandlerfactory as vhf from sahara.plugins import provisioning as p from sahara.topology import topology_helper as th from sahara.utils import cluster_progress_ops as cpo -from sahara.utils import general as g conductor = c.API @@ -73,12 +72,12 @@ class AmbariPlugin(p.ProvisioningPluginBase): # check if HDFS HA is enabled; set it up if so if cluster_spec.is_hdfs_ha_enabled(cluster): - cluster = g.change_cluster_status(cluster, "Configuring HA") self.configure_hdfs_ha(cluster) @cpo.event_wrapper( True, step=_("Add configurations to cluster"), param=('cluster', 1)) def configure_hdfs_ha(self, cluster): + LOG.debug("Configuring HDFS HA") version = cluster.hadoop_version handler = self.version_factory.get_version_handler(version) @@ -100,6 +99,7 @@ class AmbariPlugin(p.ProvisioningPluginBase): ambari_client = handler.get_ambari_client() ambari_client.setup_hdfs_ha(cluster_spec, servers, ambari_info, cluster.name) + LOG.info(_LI("Configure HDFS HA successful.")) def _get_servers(self, cluster): servers = []