Repository: tez Updated Branches: refs/heads/master e9e9db1b6 -> ac0fd8bb3
TEZ-3151. Expose DAG credentials to plugins. Contributed by Sergey Shelukhin. Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/ac0fd8bb Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/ac0fd8bb Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/ac0fd8bb Branch: refs/heads/master Commit: ac0fd8bb34ebb345d018b73e5ffebbab8343b2f9 Parents: e9e9db1 Author: Siddharth Seth <[email protected]> Authored: Mon Feb 29 16:34:00 2016 -0800 Committer: Siddharth Seth <[email protected]> Committed: Mon Feb 29 16:34:00 2016 -0800 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../main/java/org/apache/tez/serviceplugins/api/DagInfo.java | 8 ++++++++ tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java | 2 -- .../java/org/apache/tez/dag/helpers/DagInfoImplForTest.java | 6 ++++++ 4 files changed, 15 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 8084a59..47913ab 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES TEZ-3029. Add an onError method to service plugin contexts. ALL CHANGES: + TEZ-3151. Expose DAG credentials to plugins. TEZ-3149. Tez-tools: Add username in DagInfo. TEZ-2988. DAGAppMaster::shutdownTezAM should return with a no-op if it has been invoked earlier. TEZ-3147. Intermediate mem-to-mem: Fix early exit when only one segment can fit into memory http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java ---------------------------------------------------------------------- diff --git a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java index ef73343..4a8b9fa 100644 --- a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java +++ b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java @@ -14,6 +14,8 @@ package org.apache.tez.serviceplugins.api; +import org.apache.hadoop.security.Credentials; + public interface DagInfo { /** @@ -27,4 +29,10 @@ public interface DagInfo { * @return the name of the dag */ String getName(); + + /** + * Get credentials for the dag. + * @return the credentials for the dag. + */ + Credentials getCredentials(); } http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java index dd96ab2..6c8e8f9 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java @@ -86,8 +86,6 @@ public interface DAG extends DagInfo { boolean isComplete(); - Credentials getCredentials(); - UserGroupInformation getDagUGI(); ACLManager getACLManager(); http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java b/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java index f92513f..b0eeaef 100644 --- a/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java +++ b/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java @@ -14,6 +14,7 @@ package org.apache.tez.dag.helpers; +import org.apache.hadoop.security.Credentials; import org.apache.tez.serviceplugins.api.DagInfo; public class DagInfoImplForTest implements DagInfo { @@ -35,4 +36,9 @@ public class DagInfoImplForTest implements DagInfo { public String getName() { return name; } + + @Override + public Credentials getCredentials() { + return null; + } }
