openstack/deb-sahara
Code Issues Proposed changes

Remove cluster status change in HDP plugin

Browse Source 
The plugins should not be allowed to change status,
this is the engine/eventlog job.

Change-Id: Ifd1a6ddd4808f16efd9732a8ace27130d7f64f56
This commit is contained in:
Li, Chen 2015-07-20 09:11:01 +08:00
parent 29598ec9a8
commit bff7110acf
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sahara/plugins/hdp/ambariplugin.py
View File

@ -27,7 +27,6 @@ from sahara.plugins.hdp.versions import versionhandlerfactory as vhf
from sahara.plugins import provisioning as p from sahara.plugins import provisioning as p
from sahara.topology import topology_helper as th from sahara.topology import topology_helper as th
from sahara.utils import cluster_progress_ops as cpo from sahara.utils import cluster_progress_ops as cpo
from sahara.utils import general as g
conductor = c.API conductor = c.API
@ -73,12 +72,12 @@ class AmbariPlugin(p.ProvisioningPluginBase):
# check if HDFS HA is enabled; set it up if so # check if HDFS HA is enabled; set it up if so
if cluster_spec.is_hdfs_ha_enabled(cluster): if cluster_spec.is_hdfs_ha_enabled(cluster):
cluster = g.change_cluster_status(cluster, "Configuring HA")
self.configure_hdfs_ha(cluster) self.configure_hdfs_ha(cluster)
@cpo.event_wrapper( @cpo.event_wrapper(
True, step=_("Add configurations to cluster"), param=('cluster', 1)) True, step=_("Add configurations to cluster"), param=('cluster', 1))
def configure_hdfs_ha(self, cluster): def configure_hdfs_ha(self, cluster):
LOG.debug("Configuring HDFS HA")
version = cluster.hadoop_version version = cluster.hadoop_version
handler = self.version_factory.get_version_handler(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 = handler.get_ambari_client()
ambari_client.setup_hdfs_ha(cluster_spec, servers, ambari_info, ambari_client.setup_hdfs_ha(cluster_spec, servers, ambari_info,
cluster.name) cluster.name)
LOG.info(_LI("Configure HDFS HA successful."))
def _get_servers(self, cluster): def _get_servers(self, cluster):
servers = [] servers = []