This is an automated email from the ASF dual-hosted git repository.

dkuzmenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 1e75615d686 HIVE-29519: Redundant perfLogger reset and queryStartTime 
update (#6386)
1e75615d686 is described below

commit 1e75615d68637052e7734e4a3e5054a36ee2bf13
Author: Denys Kuzmenko <[email protected]>
AuthorDate: Wed Mar 25 21:37:13 2026 +0200

    HIVE-29519: Redundant perfLogger reset and queryStartTime update (#6386)
---
 ql/src/java/org/apache/hadoop/hive/ql/Driver.java        | 6 +-----
 ql/src/java/org/apache/hadoop/hive/ql/DriverContext.java | 4 ----
 2 files changed, 1 insertion(+), 9 deletions(-)

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 fa6247bedf4..40746198468 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
@@ -170,8 +170,6 @@ private void runInternal(String command, boolean 
alreadyCompiled) throws Command
 
       if (!alreadyCompiled) {
         compileInternal(command, true);
-      } else {
-        driverContext.recordQueryStartTime();
       }
 
       DriverUtils.checkInterrupted(driverState, driverContext, "at acquiring 
the lock.", null, null);
@@ -273,14 +271,12 @@ private void validateCurrentSnapshot() throws 
CommandProcessorException {
           driverContext.setRetrial(true);
 
           compileInternal(context.getCmd(), true);
+          driverContext.setRetrial(false);
 
           if (driverContext.getPlan().hasAcidResourcesInQuery()) {
             driverTxnHandler.recordValidWriteIds();
             driverTxnHandler.setWriteIdForAcidFileSinks();
           }
-          // Since we're reusing the compiled plan, we need to update its 
start time for current run
-          driverContext.recordQueryStartTime();
-          driverContext.setRetrial(false);
         }
         // Re-check snapshot only in case we had to release locks and open a 
new transaction,
         // otherwise exclusive locks should protect output tables/partitions 
in snapshot from concurrent writes.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/DriverContext.java 
b/ql/src/java/org/apache/hadoop/hive/ql/DriverContext.java
index fd2dfc2e9e3..b02161c0ca9 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/DriverContext.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/DriverContext.java
@@ -275,8 +275,4 @@ public void setExplainPlan(String explainPlan) {
   public String getExplainPlan() {
     return explainPlan;
   }
-
-  public void recordQueryStartTime() {
-    plan.setQueryStartTime(queryDisplay.getQueryStartTime());
-  }
 }

Reply via email to