You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2015/06/30 02:41:31 UTC
tez git commit: TEZ-2048. Remove
VertexManagerPluginContext.getTaskContainer() (bikas)
Repository: tez
Updated Branches:
refs/heads/master 1421f5968 -> 462d18501
TEZ-2048. Remove VertexManagerPluginContext.getTaskContainer() (bikas)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/462d1850
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/462d1850
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/462d1850
Branch: refs/heads/master
Commit: 462d18501326bf988e255014d732e4d6bbf82ebf
Parents: 1421f59
Author: Bikas Saha <bi...@apache.org>
Authored: Mon Jun 29 17:41:19 2015 -0700
Committer: Bikas Saha <bi...@apache.org>
Committed: Mon Jun 29 17:41:19 2015 -0700
----------------------------------------------------------------------
CHANGES.txt | 1 +
.../apache/tez/dag/api/VertexManagerPluginContext.java | 8 --------
.../org/apache/tez/dag/app/dag/impl/VertexManager.java | 13 -------------
3 files changed, 1 insertion(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tez/blob/462d1850/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index bd1e83b..63b7091 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -5,6 +5,7 @@ Apache Tez Change Log
Release 0.8.0: Unreleased
INCOMPATIBLE CHANGES
+ TEZ-2048. Remove VertexManagerPluginContext.getTaskContainer()
TEZ-2565. Consider scanning unfinished tasks in VertexImpl::constructStatistics to reduce merge overhead.
TEZ-2552. CRC errors can cause job to run for very long time in large jobs.
TEZ-2468. Change the minimum Java version to Java 7.
http://git-wip-us.apache.org/repos/asf/tez/blob/462d1850/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java
----------------------------------------------------------------------
diff --git a/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java b/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java
index a6096d8..1b012ae 100644
--- a/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java
+++ b/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java
@@ -113,14 +113,6 @@ public interface VertexManagerPluginContext {
Resource getVertexTaskResource();
/**
- * Get the container for the successful attempt of the task
- * @return YARN container for the successful task. Maybe null if there is no
- * successful task.
- */
- @Deprecated
- public Container getTaskContainer(String vertexName, Integer taskIndex);
-
- /**
* Get the total resource allocated to this vertex. If the DAG is running in
* a busy cluster then it may have no resources available dedicated to it. The
* DAG may divide its available resource among member vertices.
http://git-wip-us.apache.org/repos/asf/tez/blob/462d1850/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java
index 945d9ba..caa3432 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java
@@ -295,19 +295,6 @@ public class VertexManager {
return appContext.getTaskScheduler().getNumClusterNodes();
}
- // TODO TEZ-2048. Remove this API
- @Override
- public synchronized Container getTaskContainer(String vertexName, Integer taskIndex) {
- checkAndThrowIfDone();
- Vertex vertex = appContext.getCurrentDAG().getVertex(vertexName);
- Task task = vertex.getTask(taskIndex.intValue());
- TaskAttempt attempt = task.getSuccessfulAttempt();
- if (attempt != null) {
- return attempt.getAssignedContainer();
- }
- return null;
- }
-
@Override
public synchronized void registerForVertexStateUpdates(String vertexName, Set<VertexState> stateSet) {
checkAndThrowIfDone();