tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject tez git commit: TEZ-3032. Addendum patch. DAG start time getting logged using system time instead of recorded time in startTime field. (hitesh)
Date Thu, 14 Jan 2016 23:00:18 GMT
Repository: tez
Updated Branches:
  refs/heads/master b47af5729 -> d0348b03b


TEZ-3032. Addendum patch. DAG start time getting logged using system time instead of recorded
time in startTime field. (hitesh)


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

Branch: refs/heads/master
Commit: d0348b03b84bc83e0fc503e424f7ae57fa86cc90
Parents: b47af57
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Jan 14 14:59:59 2016 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Jan 14 14:59:59 2016 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/d0348b03/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
index 139fd51..dd6f834 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
@@ -1245,9 +1245,8 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
     if (recoveryData == null
         || recoveryData.getDAGFinishedEvent() == null) {
       Map<String, Integer> taskStats = constructTaskStats(getDAGProgress());
-
       DAGFinishedEvent finishEvt = new DAGFinishedEvent(dagId, startTime,
-          clock.getTime(), state,
+          finishTime, state,
           StringUtils.join(getDiagnostics(), LINE_SEPARATOR),
           counters, this.userName, this.dagName, taskStats,
           this.appContext.getApplicationAttemptId(), this.jobPlan);


Mime
View raw message