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

zhangbutao 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 d203bf9e03e HIVE-27961: Beeline will print duplicate stats info when 
hive.tez.exec.print.summary is true (#4960)(Butao Zhang, reviewed by Attila 
Turoczy, Sourabh Badhya)
d203bf9e03e is described below

commit d203bf9e03e51b01b75a0bfaa27e8749271fcafa
Author: Butao Zhang <[email protected]>
AuthorDate: Sun Dec 24 21:20:58 2023 +0800

    HIVE-27961: Beeline will print duplicate stats info when 
hive.tez.exec.print.summary is true (#4960)(Butao Zhang, reviewed by Attila 
Turoczy, Sourabh Badhya)
---
 ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStatsTask.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStatsTask.java 
b/ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStatsTask.java
index ed968edce0c..96f43c426c8 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStatsTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/stats/BasicStatsTask.java
@@ -311,8 +311,9 @@ public class BasicStatsTask implements Serializable, 
IStatsProcessor {
 
         if (conf.getBoolVar(ConfVars.TEZ_EXEC_SUMMARY)) {
           console.printInfo("Table " + tableFullName + " stats: [" + 
toString(p.getPartParameters()) + ']');
+        } else {
+          LOG.info("Table " + tableFullName + " stats: [" + 
toString(p.getPartParameters()) + ']');
         }
-        LOG.info("Table " + tableFullName + " stats: [" + 
toString(p.getPartParameters()) + ']');
 
         // The table object is assigned to the latest table object.
         // So that it can be used by ColStatsProcessor.
@@ -377,8 +378,9 @@ public class BasicStatsTask implements Serializable, 
IStatsProcessor {
           updates.add((Partition) res);
           if (conf.getBoolVar(ConfVars.TEZ_EXEC_SUMMARY)) {
             console.printInfo("Partition " + 
basicStatsProcessor.partish.getPartition().getSpec() + " stats: [" + 
toString(basicStatsProcessor.partish.getPartParameters()) + ']');
+          } else {
+            LOG.info("Partition " + 
basicStatsProcessor.partish.getPartition().getSpec() + " stats: [" + 
toString(basicStatsProcessor.partish.getPartParameters()) + ']');
           }
-          LOG.info("Partition " + 
basicStatsProcessor.partish.getPartition().getSpec() + " stats: [" + 
toString(basicStatsProcessor.partish.getPartParameters()) + ']');
         }
 
         if (!updates.isEmpty()) {

Reply via email to