Cluster scaling bug fixing:

Fixes: bug #1203041

Change-Id: Ib1fae214f6b49262b60fd5326156560000552407
This commit is contained in:
Nadya Privalova 2013-07-19 16:45:51 +04:00
parent e9eb475891
commit c545e24e7a

View File

@ -160,7 +160,9 @@ class VanillaProvider(p.ProvisioningPluginBase):
self._write_hadoop_user_keys(cluster.private_key,
instances)
run.refresh_nodes(utils.get_namenode(cluster).remote, "dfsadmin")
run.refresh_nodes(utils.get_jobtracker(cluster).remote, "mradmin")
jt = utils.get_jobtracker(cluster)
if jt:
run.refresh_nodes(jt.remote, "mradmin")
for i in instances:
with i.remote as remote: