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());
- }
}