diff --git a/releasenotes/notes/ambari-downscaling-b9ba759ce9c7325e.yaml b/releasenotes/notes/ambari-downscaling-b9ba759ce9c7325e.yaml
new file mode 100644
index 00000000..89bf9d88
--- /dev/null
+++ b/releasenotes/notes/ambari-downscaling-b9ba759ce9c7325e.yaml
@@ -0,0 +1,3 @@
+---
+fixes:
+  - Fixed incorrect down scaling of ambari cluster
diff --git a/sahara/plugins/ambari/client.py b/sahara/plugins/ambari/client.py
index 9c111c8e..f76f0d93 100644
--- a/sahara/plugins/ambari/client.py
+++ b/sahara/plugins/ambari/client.py
@@ -194,6 +194,19 @@ class AmbariClient(object):
 
             self.wait_ambari_request(self.req_id(resp), cluster_name)
 
+    def restart_namenode(self, cluster_name, instance):
+        url = self._base_url + "/clusters/%s/requests" % cluster_name
+        data = d_helper.build_namenode_restart_request(cluster_name, instance)
+        resp = self.post(url, data=jsonutils.dumps(data))
+        self.wait_ambari_request(self.req_id(resp), cluster_name)
+
+    def restart_resourcemanager(self, cluster_name, instance):
+        url = self._base_url + "/clusters/%s/requests" % cluster_name
+        data = d_helper.build_resourcemanager_restart_request(cluster_name,
+                                                              instance)
+        resp = self.post(url, data=jsonutils.dumps(data))
+        self.wait_ambari_request(self.req_id(resp), cluster_name)
+
     def delete_host(self, cluster_name, instance):
         url = self._base_url + "/clusters/%s/hosts/%s" % (cluster_name,
                                                           instance.fqdn())
diff --git a/sahara/plugins/ambari/deploy.py b/sahara/plugins/ambari/deploy.py
index fa1a2eb3..891aee4f 100644
--- a/sahara/plugins/ambari/deploy.py
+++ b/sahara/plugins/ambari/deploy.py
@@ -345,6 +345,32 @@ def decommission_datanodes(cluster, instances):
         client.decommission_datanodes(cluster.name, instances)
 
 
+def restart_namenode(cluster, instance):
+    ambari = plugin_utils.get_instance(cluster, p_common.AMBARI_SERVER)
+    password = cluster.extra["ambari_password"]
+
+    with ambari_client.AmbariClient(ambari, password=password) as client:
+        client.restart_namenode(cluster.name, instance)
+
+
+def restart_resourcemanager(cluster, instance):
+    ambari = plugin_utils.get_instance(cluster, p_common.AMBARI_SERVER)
+    password = cluster.extra["ambari_password"]
+
+    with ambari_client.AmbariClient(ambari, password=password) as client:
+        client.restart_resourcemanager(cluster.name, instance)
+
+
+def restart_nns_and_rms(cluster):
+    nns = plugin_utils.get_instances(cluster, p_common.NAMENODE)
+    for nn in nns:
+        restart_namenode(cluster, nn)
+
+    rms = plugin_utils.get_instances(cluster, p_common.RESOURCEMANAGER)
+    for rm in rms:
+        restart_resourcemanager(cluster, rm)
+
+
 def remove_services_from_hosts(cluster, instances):
     for inst in instances:
         LOG.debug("Stopping and removing processes from host %s" % inst.fqdn())
diff --git a/sahara/plugins/ambari/plugin.py b/sahara/plugins/ambari/plugin.py
index 5ce42197..cfad8a33 100644
--- a/sahara/plugins/ambari/plugin.py
+++ b/sahara/plugins/ambari/plugin.py
@@ -187,6 +187,7 @@ class AmbariPluginProvider(p.ProvisioningPluginBase):
     def decommission_nodes(self, cluster, instances):
         deploy.decommission_hosts(cluster, instances)
         deploy.remove_services_from_hosts(cluster, instances)
+        deploy.restart_nns_and_rms(cluster)
 
     def validate_scaling(self, cluster, existing, additional):
         validation.validate(cluster.id)