HIVE-10957 : QueryPlan's start time is incorrect in certain cases (Wei Zheng, reviewed by Gunther Hagleitner)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/0be14eac Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/0be14eac Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/0be14eac Branch: refs/heads/branch-1.2 Commit: 0be14eac89df5946ddbb699fb9cf39b76d470a00 Parents: 49c5c92 Author: Thejas Nair <[email protected]> Authored: Tue Jun 9 14:21:36 2015 -0700 Committer: Thejas Nair <[email protected]> Committed: Tue Jun 9 14:21:53 2015 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/Driver.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/0be14eac/ql/src/java/org/apache/hadoop/hive/ql/Driver.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java index 338e755..847d9a1 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -1171,6 +1171,9 @@ public class Driver implements CommandProcessor { if (ret != 0) { return createProcessorResponse(ret); } + } else { + // Since we're reusing the compiled plan, we need to update its start time for current run + plan.setQueryStartTime(perfLogger.getStartTime(PerfLogger.DRIVER_RUN)); } // the reason that we set the txn manager for the cxt here is because each
