Author: croberts
Date: 2013-06-20 16:29:48 +0000 (Thu, 20 Jun 2013)
New Revision: 5762
Modified:
trunk/cumin/python/cumin/gridhadoop/jobtracker.py
trunk/cumin/python/cumin/gridhadoop/namenode.py
Log:
Now passing host to add_external calls.
Modified: trunk/cumin/python/cumin/gridhadoop/jobtracker.py
===================================================================
--- trunk/cumin/python/cumin/gridhadoop/jobtracker.py 2013-06-20 15:20:44 UTC (rev 5761)
+++ trunk/cumin/python/cumin/gridhadoop/jobtracker.py 2013-06-20 16:29:48 UTC (rev 5762)
@@ -101,7 +101,8 @@
def do_invoke(self, session, object, invoc, args):
self.invoc = invoc
(ipc, http) = args
- self.app.remote.add_external_job_tracker(ipc, http, invoc.make_callback())
+ host = self.app.remote.get_hosts("SCHEDULER", "HADOOP")[0]
+ self.app.remote.add_external_job_tracker(host, ipc, http, invoc.make_callback())
def get_title(self, session, x):
return "Add an infrastructure job tracker"
Modified: trunk/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- trunk/cumin/python/cumin/gridhadoop/namenode.py 2013-06-20 15:20:44 UTC (rev 5761)
+++ trunk/cumin/python/cumin/gridhadoop/namenode.py 2013-06-20 16:29:48 UTC (rev 5762)
@@ -100,7 +100,8 @@
def do_invoke(self, session, object, invoc, args):
self.invoc = invoc
(ipc, http) = args
- self.app.remote.add_external_name_node(ipc, http, invoc.make_callback())
+ host = self.app.remote.get_hosts("SCHEDULER", "HADOOP")[0]
+ self.app.remote.add_external_name_node(host, ipc, http, invoc.make_callback())
def get_title(self, session, x):
return "Add an infrastructure name node"
Show replies by date