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()) {