You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by sr...@apache.org on 2016/01/20 18:05:46 UTC
[20/50] [abbrv] tez git commit: TEZ-3032. Addendum patch. DAG start
time getting logged using system time instead of recorded time in startTime
field. (hitesh)
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/TEZ-2980
Commit: d0348b03b84bc83e0fc503e424f7ae57fa86cc90
Parents: b47af57
Author: Hitesh Shah <hi...@apache.org>
Authored: Thu Jan 14 14:59:59 2016 -0800
Committer: Hitesh Shah <hi...@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);