Author: croberts
Date: 2012-12-14 22:07:55 +0000 (Fri, 14 Dec 2012)
New Revision: 5604
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
branches/elephant/sage/python/sage/aviary/aviaryoperations.py
Log:
stop_name_node is now wired-in and working. Name nodes are functional!
Modified: branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2012-12-14 21:39:45 UTC
(rev 5603)
+++ branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2012-12-14 22:07:55 UTC
(rev 5604)
@@ -135,7 +135,7 @@
def do_invoke(self, invoc, id, args):
self.invoc = invoc
(hadoophost) = args
- self.app.remote.stop_name_node(hadoophost, id, invoc.make_callback())
+ self.app.remote.stop_name_node(hadoophost, [float(id)], invoc.make_callback())
def get_title(self, session):
return "Remove name nodes"
@@ -153,7 +153,7 @@
if not self.errors.get(session):
#TODO get hosts associated with each id
- hadoophost = "TODO"
+ hadoophost = "grid2.lab.bos.redhat.com:9090"
self.task.invoke(session, ids, (hadoophost))
def render_title(self, session):
Modified: branches/elephant/sage/python/sage/aviary/aviaryoperations.py
===================================================================
--- branches/elephant/sage/python/sage/aviary/aviaryoperations.py 2012-12-14 21:39:45 UTC
(rev 5603)
+++ branches/elephant/sage/python/sage/aviary/aviaryoperations.py 2012-12-14 22:07:55 UTC
(rev 5604)
@@ -994,7 +994,7 @@
if type(id) in (str,unicode):
new_ref.ipc = id
else:
- new_ref.id = int(id)
+ new_ref.id = float(id)
except Exception:
raise Exception("Invalid HadoopID value")
refs.append(new_ref)
Show replies by date