From e365766cca1a3ddb90246f092b2d8acefee30516 Mon Sep 17 00:00:00 2001 From: Denys Kuzmenko Date: Sat, 21 Mar 2026 08:35:29 +0200 Subject: [PATCH] HIVE-29519: Redundant perfLogger reset and queryStartTime update --- 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 fa6247bedf4a..40746198468e 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 fd2dfc2e9e3f..b02161c0ca93 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()); - } }