You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2014/06/21 00:35:56 UTC
[18/23] 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/66626053
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/66626053
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/66626053
Branch: refs/heads/branch-0.4.1-incubating
Commit: 6662605342e17335c31ad9177017d898e13f532d
Parents: b82d5f3
Author: Hitesh Shah <hi...@apache.org>
Authored: Thu Apr 3 17:04:07 2014 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Fri Jun 20 15:34:45 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/66626053/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();