tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-312. AppMasterUGI should take tokens from currentUser UGI when starting AM. (hitesh)
Date Mon, 22 Jul 2013 20:07:27 GMT
Updated Branches:
  refs/heads/master 85d073153 -> f5ed2e258


TEZ-312. AppMasterUGI should take tokens from currentUser UGI when starting AM. (hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/f5ed2e25
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/f5ed2e25
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/f5ed2e25

Branch: refs/heads/master
Commit: f5ed2e2588f0241f3b8b4e25928b92e9b9556a43
Parents: 85d0731
Author: Hitesh Shah <hitesh@apache.org>
Authored: Mon Jul 22 11:40:11 2013 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Mon Jul 22 11:40:11 2013 -0700

----------------------------------------------------------------------
 tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/f5ed2e25/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
index 6a5ff15..b04701a 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
@@ -1081,10 +1081,12 @@ public class DAGAppMaster extends CompositeService {
   protected static void initAndStartAppMaster(final DAGAppMaster appMaster,
       final TezConfiguration conf, String jobUserName) throws IOException,
       InterruptedException {
+    Credentials credentials =
+        UserGroupInformation.getCurrentUser().getCredentials();
     UserGroupInformation.setConfiguration(conf);
     UserGroupInformation appMasterUgi = UserGroupInformation
         .createRemoteUser(jobUserName);
-    appMasterUgi.addCredentials(UserGroupInformation.getCurrentUser().getCredentials());
+    appMasterUgi.addCredentials(credentials);
     appMasterUgi.doAs(new PrivilegedExceptionAction<Object>() {
       @Override
       public Object run() throws Exception {


Mime
View raw message