Repository: tez Updated Branches: refs/heads/master 3bb93de65 -> 5b1f1a923
TEZ-3120. Remove TaskCommContext.getCurrentDagName, Identifier. Contributed by Tsuyoshi Ozawa. Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/43e9c020 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/43e9c020 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/43e9c020 Branch: refs/heads/master Commit: 43e9c020bed2dde302d143e70e2d0092abc059f4 Parents: 3bb93de Author: Siddharth Seth <[email protected]> Authored: Thu Apr 7 10:44:11 2016 -0700 Committer: Siddharth Seth <[email protected]> Committed: Thu Apr 7 10:44:11 2016 -0700 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../tez/dag/app/TaskCommunicatorContextImpl.java | 12 ------------ .../api/TaskCommunicatorContext.java | 19 ------------------- 3 files changed, 1 insertion(+), 31 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/43e9c020/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 1178d0e..1b419ac 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -5,6 +5,7 @@ Release 0.8.3: Unreleased INCOMPATIBLE CHANGES TEZ-3029. Add an onError method to service plugin contexts. + TEZ-3120. Remove TaskCommContext.getCurrentDagName, Identifier. ALL CHANGES: TEZ-3161. Allow task to report different kinds of errors - fatal / kill. http://git-wip-us.apache.org/repos/asf/tez/blob/43e9c020/tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java index a922f38..c31567b 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java @@ -146,23 +146,11 @@ public class TaskCommunicatorContextImpl implements TaskCommunicatorContext, Ver this); } - @SuppressWarnings("deprecation") - @Override - public String getCurrentDagName() { - return getDag().getName(); - } - @Override public String getCurrentAppIdentifier() { return context.getApplicationID().toString(); } - @SuppressWarnings("deprecation") - @Override - public int getCurrentDagIdenitifer() { - return getDag().getID().getId(); - } - @Nullable @Override public DagInfo getCurrentDagInfo() { http://git-wip-us.apache.org/repos/asf/tez/blob/43e9c020/tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java b/tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java index 4990d95..2de2f45 100644 --- a/tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java +++ b/tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java @@ -165,31 +165,12 @@ public interface TaskCommunicatorContext extends ServicePluginContextBase { */ void registerForVertexStateUpdates(String vertexName, @Nullable Set<VertexState> stateSet); - // TODO TEZ-3120 Remove deprecated methods - /** - * Get the name of the currently executing dag - * - * @return the name of the currently executing dag - * @deprecated replaced by {@link TaskCommunicatorContext#getCurrentDagInfo} - */ - @Deprecated - String getCurrentDagName(); - /** * Get an identifier for the executing context of the DAG. * @return a String identifier for the exeucting context. */ String getCurrentAppIdentifier(); - // TODO TEZ-3120 Remove deprecated methods - /** - * Get the identifier for the currently executing dag. - * @return a numerical identifier for the currently running DAG. This is unique within the currently running application. - * @deprecated replaced by {@link TaskCommunicatorContext#getCurrentDagInfo} - */ - @Deprecated - int getCurrentDagIdenitifer(); - /** * Get the name of the Input vertices for the specified vertex. * Root Inputs are not returned.
