It appears that there is an error in hdfs_helper.py:
~~~~~~ def _get_cluster_hosts_information(host, cluster): for clust in conductor.cluster_get_all(context.ctx()): if clust.id == cluster.id: continue
for i in u.get_instances(***c***): if i.instance_name == host: return g.generate_etc_hosts(***c***)
return None ~~~~~~
Should probably be:
for i in u.get_instances(***clust***): if i.instance_name == host: return g.generate_etc_hosts(***clust***)
It appears that there is an error in hdfs_helper.py:
~~~~~~ hosts_informati on(host, cluster): cluster_ get_all( context. ctx()):
continue
def _get_cluster_
for clust in conductor.
if clust.id == cluster.id:
for i in u.get_instances (***c** *):
return g.generate_ etc_hosts( ***c*** )
if i.instance_name == host:
return None
~~~~~~
Should probably be:
~~~~~~ hosts_informati on(host, cluster): cluster_ get_all( context. ctx()):
continue
def _get_cluster_
for clust in conductor.
if clust.id == cluster.id:
for i in u.get_instances (***clust* **):
return g.generate_ etc_hosts( ***clust* **)
if i.instance_name == host:
return None
~~~~~~