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):
cumin-developers@lists.fedorahosted.org