Author: croberts
Date: 2012-12-17 17:07:54 +0000 (Mon, 17 Dec 2012)
New Revision: 5608
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
branches/elephant/sage/python/sage/aviary/aviaryoperations.py
Log:
Fixing a couple of type-o's for task trackers.
Modified: branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2012-12-17 17:01:11 UTC
(rev 5607)
+++ branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2012-12-17 17:07:54 UTC
(rev 5608)
@@ -115,7 +115,7 @@
(binfile, owner, hadoophost, count, job_tracker) = args
try:
- self.app.remote.start_data_node(hadoophost, float(job_tracker), binfile,
owner, count, invoc.make_callback())
+ self.app.remote.start_task_tracker(hadoophost, float(job_tracker), binfile,
owner, count, invoc.make_callback())
except Exception, e:
invoc.status = invoc.FAILED
log.debug("Creating task trackers failed", exc_info=True)
Modified: branches/elephant/sage/python/sage/aviary/aviaryoperations.py
===================================================================
--- branches/elephant/sage/python/sage/aviary/aviaryoperations.py 2012-12-17 17:01:11 UTC
(rev 5607)
+++ branches/elephant/sage/python/sage/aviary/aviaryoperations.py 2012-12-17 17:07:54 UTC
(rev 5608)
@@ -963,7 +963,7 @@
self._operate_on_ids(host, ids, callback, "stopTaskTracker")
def start_task_tracker(self, host, nn_id, bin_file, owner, count, callback):
- return self._start_node(host, name_node_id, bin_file, owner, count,
+ return self._start_node(host, nn_id, bin_file, owner, count,
"startTaskTracker", callback)
def get_task_tracker(self, host, ids, callback=None):