tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject [2/2] git commit: TEZ-1014. Add a log message to indicate last AM attempt. (hitesh)
Date Fri, 04 Apr 2014 00:04:38 GMT
TEZ-1014. Add a log message to indicate last AM attempt. (hitesh)


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

Branch: refs/heads/master
Commit: f8f5411ea0c17496090b65562f3b4b2da48cd059
Parents: d418196
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Apr 3 17:04:07 2014 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Apr 3 17:04:07 2014 -0700

----------------------------------------------------------------------
 tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/f8f5411e/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
index 8d1fc1c..94857b4 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
@@ -350,6 +350,9 @@ public class DAGAppMaster extends AbstractService {
         clientRpcServer, dispatcher.getEventHandler(), containerSignatureMatcher);
     addIfService(taskSchedulerEventHandler, true);
     if (isLastAMRetry) {
+      LOG.info("AM will unregister as this is the last attempt"
+          + ", currentAttempt=" + appAttemptID.getAttemptId()
+          + ", maxAttempts=" + maxAppAttempts);
       this.taskSchedulerEventHandler.setShouldUnregisterFlag();
     }
 
@@ -448,6 +451,7 @@ public class DAGAppMaster extends AbstractService {
       DAGAppMasterEventDAGFinished finishEvt =
           (DAGAppMasterEventDAGFinished) event;
       if (!isSession) {
+        LOG.info("Not a session, AM will unregister as DAG has completed");
         this.taskSchedulerEventHandler.setShouldUnregisterFlag();
         _updateLoggers(currentDAG, "_post");
         setStateOnDAGCompletion();


Mime
View raw message