Author: croberts
Date: 2013-01-03 15:58:07 +0000 (Thu, 03 Jan 2013)
New Revision: 5632
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
Log:
Additional form/code cleanup
Modified: branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-03 14:46:30 UTC
(rev 5631)
+++ branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-03 15:58:07 UTC
(rev 5632)
@@ -161,7 +161,7 @@
def render_title(self, session):
return "Create data nodes"
- class CountField(StringField):
+ class CountField(IntegerField):
def render_title(self, session):
return "Number of data nodes to start"
Modified: branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-03 14:46:30 UTC
(rev 5631)
+++ branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-03 15:58:07 UTC
(rev 5632)
@@ -38,11 +38,7 @@
def render_title(self, session):
return "Hadoop job trackers"
-
- def get_qmf_results(self, session):
- values = self.get_data_values(session)
- return self.table.adapter.get_sage_results(values)
-
+
class JobTrackerTable(ObjectQmfSelectorTable):
def __init__(self, app, name, cls):
super(JobTrackerTable, self).__init__(app, name, cls)
@@ -117,7 +113,7 @@
(binfile, owner, hadoophost, name_node, count) = args
try:
- self.app.remote.start_job_tracker(hadoophost, float(name_node), binfile,
owner, count, invoc.make_callback())
+ self.app.remote.start_job_tracker(hadoophost, name_node, binfile, owner,
count, invoc.make_callback())
except Exception, e:
invoc.status = invoc.FAILED
log.debug("Creating job tracker failed", exc_info=True)
Show replies by date