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 <[email protected]> Authored: Thu Jan 14 14:59:59 2016 -0800 Committer: Hitesh Shah <[email protected]> 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);
