tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject [07/50] [abbrv] tez git commit: TEZ-2048. Remove VertexManagerPluginContext.getTaskContainer() (bikas)
Date Wed, 15 Jul 2015 00:25:40 GMT
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/TEZ-2003
Commit: 462d18501326bf988e255014d732e4d6bbf82ebf
Parents: 1421f59
Author: Bikas Saha <bikas@apache.org>
Authored: Mon Jun 29 17:41:19 2015 -0700
Committer: Bikas Saha <bikas@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();


Mime
View raw message