(hive) branch master updated: HIVE-21520: Query 'Submit plan' time reported is incorrect (#4996) (Butao Zhang reviewed by Laszlo Bodor)

[abstractdog]

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

abstractdog 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 ce0823896aa HIVE-21520: Query 'Submit plan' time reported is incorrect 
(#4996) (Butao Zhang reviewed by Laszlo Bodor)
ce0823896aa is described below

commit ce0823896aa6bf3be062764a61ecef1aba309db5
Author: Butao Zhang <zhangbu...@cmss.chinamobile.com>
AuthorDate: Wed Jan 17 17:04:14 2024 +0800

    HIVE-21520: Query 'Submit plan' time reported is incorrect (#4996) (Butao 
Zhang reviewed by Laszlo Bodor)
---
 ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java          | 2 +-
 .../org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
index 48e907b20ab..8935843ae83 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
@@ -258,7 +258,7 @@ public class TezTask extends Task<TezWork> {
         LogUtils.putToMDC(LogUtils.DAGID_KEY, dagId);
 
         // finally monitor will print progress until the job is done
-        TezJobMonitor monitor = new TezJobMonitor(work.getAllWork(), 
dagClient, conf, dag, ctx, counters);
+        TezJobMonitor monitor = new TezJobMonitor(work.getAllWork(), 
dagClient, conf, dag, ctx, counters, perfLogger);
         rc = monitor.monitorExecution();
 
         if (rc != 0) {
diff --git 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java
index 17ab6e39397..fbbbf189e48 100644
--- 
a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java
+++ 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java
@@ -77,7 +77,7 @@ public class TezJobMonitor {
   private static final int MAX_RETRY_INTERVAL = 2500;
   private static final int MAX_RETRY_FAILURES = (MAX_RETRY_INTERVAL / 
MAX_CHECK_INTERVAL) + 1;
 
-  private final PerfLogger perfLogger = SessionState.getPerfLogger();
+  private final PerfLogger perfLogger;
   private static final List<DAGClient> shutdownList;
   private final List<BaseWork> topSortedWorks;
 
@@ -117,7 +117,7 @@ public class TezJobMonitor {
   private final TezCounters counters;
 
   public TezJobMonitor(List<BaseWork> topSortedWorks, final DAGClient 
dagClient, HiveConf conf, DAG dag,
-    Context ctx, final TezCounters counters) {
+    Context ctx, final TezCounters counters, PerfLogger perfLogger) {
     this.topSortedWorks = topSortedWorks;
     this.dagClient = dagClient;
     this.hiveConf = conf;
@@ -126,6 +126,7 @@ public class TezJobMonitor {
     console = SessionState.getConsole();
     updateFunction = updateFunction();
     this.counters = counters;
+    this.perfLogger = perfLogger;
   }
 
   private RenderStrategy.UpdateFunction updateFunction() {