You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/04/04 02:04:38 UTC
[2/2] git commit: TEZ-1014. Add a log message to indicate last AM
attempt. (hitesh)
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 <hi...@apache.org>
Authored: Thu Apr 3 17:04:07 2014 -0700
Committer: Hitesh Shah <hi...@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();