You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2016/03/01 01:34:24 UTC
tez git commit: TEZ-3151. Expose DAG credentials to plugins.
Contributed by Sergey Shelukhin.
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 <ss...@apache.org>
Authored: Mon Feb 29 16:34:00 2016 -0800
Committer: Siddharth Seth <ss...@apache.org>
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;
+ }
}