TEZ-3032. 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/37e70146 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/37e70146 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/37e70146 Branch: refs/heads/TEZ-2980 Commit: 37e70146e9c6162c048af2388f732a701654cda9 Parents: b656157 Author: Hitesh Shah <[email protected]> Authored: Thu Jan 14 13:49:17 2016 -0800 Committer: Hitesh Shah <[email protected]> Committed: Thu Jan 14 13:49:17 2016 -0800 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/37e70146/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index ec3e84b..ca668a0 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -18,6 +18,7 @@ INCOMPATIBLE CHANGES TEZ-2972. Avoid task rescheduling when a node turns unhealthy ALL CHANGES: + TEZ-3032. DAG start time getting logged using system time instead of recorded time in startTime field. TEZ-2669. Propagation of errors from plugins to the AM for error reporting. TEZ-2978. Add an option to allow the SplitGrouper to generate node local only groups. TEZ-2129. Task and Attempt views should contain links to the logs @@ -312,6 +313,7 @@ INCOMPATIBLE CHANGES TEZ-2949. Allow duplicate dag names within session for Tez. ALL CHANGES + TEZ-3032. DAG start time getting logged using system time instead of recorded time in startTime field. TEZ-2129. Task and Attempt views should contain links to the logs TEZ-3025. InputInitializer creation should use the dag ugi. TEZ-3017. HistoryACLManager does not have a close method for cleanup http://git-wip-us.apache.org/repos/asf/tez/blob/37e70146/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 41017ea..139fd51 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 @@ -1222,7 +1222,7 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG, if (recoveryData == null || recoveryData.getDAGStartedEvent() == null) { DAGStartedEvent startEvt = new DAGStartedEvent(this.dagId, - clock.getTime(), this.userName, this.dagName); + this.startTime, this.userName, this.dagName); this.appContext.getHistoryHandler().handle( new DAGHistoryEvent(dagId, startEvt)); }
