tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject git commit: Log different messages for valid containers which are being told to die versus Invalid containers. Contributed by joeyli.
Date Fri, 16 Aug 2013 17:27:12 GMT
Updated Branches:
  refs/heads/master 883bc3626 -> 778ad2438


Log different messages for valid containers which are being told to die
 versus Invalid containers. Contributed by joeyli.


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/778ad243
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/778ad243
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/778ad243

Branch: refs/heads/master
Commit: 778ad2438416f0241fa6a7ce84b35d5c5ec068a6
Parents: 883bc36
Author: Siddharth Seth <sseth@apache.org>
Authored: Fri Aug 16 10:25:49 2013 -0700
Committer: Siddharth Seth <sseth@apache.org>
Committed: Fri Aug 16 10:25:49 2013 -0700

----------------------------------------------------------------------
 .../org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/778ad243/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
b/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
index 244d7d5..1ba76fc 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
@@ -205,8 +205,12 @@ public class TaskAttemptListenerImpTezDag extends AbstractService implements
         LOG.debug("Container with id: " + containerId + " asked for a task");
       }
       if (!registeredContainers.contains(containerId)) {
-        LOG.info("Container with id: " + containerId
-            + " is invalid and will be killed");
+        if(context.getAllContainers().get(containerId) == null)
+          LOG.info("Container with id: " + containerId
+              + " is invalid and will be killed");
+        else
+          LOG.info("Container with id: " + containerId
+              + " is valid and will be killed");              
         task = TASK_FOR_INVALID_JVM;
       } else {
         pingContainerHeartbeatHandler(containerId);


Mime
View raw message