Author: croberts
Date: 2013-01-02 18:28:38 +0000 (Wed, 02 Jan 2013)
New Revision: 5627
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
Log:
Now defaulting the owner of hadoop jobs to the current cumin user name.
Modified: branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-02 18:06:09 UTC
(rev 5626)
+++ branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-02 18:28:38 UTC
(rev 5627)
@@ -134,9 +134,6 @@
self.binfile = BinFileLoc(app, "binfile")
self.add_field(self.binfile)
- self.owner = Owner(app, "owner")
- self.add_field(self.owner)
-
self.count = self.CountField(app, "count")
self.add_field(self.count)
@@ -154,7 +151,7 @@
if not self.errors.get(session):
binfile = self.binfile.get(session)
- owner = self.owner.get(session)
+ owner = session.app.user
hadoophost = self.hadoophost.get(session)
count = self.count.get(session)
name_node = self.nameNode.get(session)
Modified: branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-02 18:06:09 UTC
(rev 5626)
+++ branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-02 18:28:38 UTC
(rev 5627)
@@ -137,9 +137,6 @@
self.binfile = BinFileLoc(app, "binfile")
self.add_field(self.binfile)
- self.owner = Owner(app, "owner")
- self.add_field(self.owner)
-
self.count = self.CountField(app, "count")
self.add_field(self.count)
@@ -157,7 +154,7 @@
if not self.errors.get(session):
binfile = self.binfile.get(session)
- owner = self.owner.get(session)
+ owner = session.app.user
hadoophost = self.hadoophost.get(session)
name_node = self.nameNode.get(session)
count = self.count.get(session)
Modified: branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2013-01-02 18:06:09 UTC
(rev 5626)
+++ branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2013-01-02 18:28:38 UTC
(rev 5627)
@@ -85,10 +85,7 @@
self.binfile = BinFileLoc(app, "binfile")
self.add_field(self.binfile)
-
- self.owner = Owner(app, "owner")
- self.add_field(self.owner)
-
+
self.hadoophost = HadoopHostField(app, "hadoophost")
self.add_field(self.hadoophost)
@@ -103,8 +100,8 @@
if not self.errors.get(session):
binfile = self.binfile.get(session)
- owner = self.owner.get(session)
hadoophost = self.hadoophost.get(session)
+ owner = session.app.user
self.task.invoke(session, None, (binfile, owner, hadoophost))
self.task.exit_with_redirect(session, url)
Modified: branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-02 18:06:09 UTC
(rev 5626)
+++ branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-02 18:28:38 UTC
(rev 5627)
@@ -133,10 +133,7 @@
self.binfile = BinFileLoc(app, "binfile")
self.add_field(self.binfile)
-
- self.owner = Owner(app, "owner")
- self.add_field(self.owner)
-
+
self.count = self.CountField(app, "count")
self.add_field(self.count)
@@ -154,7 +151,7 @@
if not self.errors.get(session):
binfile = self.binfile.get(session)
- owner = self.owner.get(session)
+ owner = session.app.user
hadoophost = self.hadoophost.get(session)
count = self.count.get(session)
job_tracker = self.jobTracker.get(session)
Show replies by date