You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2019/03/30 01:21:55 UTC
[hive] branch branch-3 updated: HIVE-21342: Analyze compute stats
for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus
Camacho Rodriguez)
This is an automated email from the ASF dual-hosted git repository.
jcamacho pushed a commit to branch branch-3
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/branch-3 by this push:
new 4015a5a HIVE-21342: Analyze compute stats for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus Camacho Rodriguez)
4015a5a is described below
commit 4015a5a9cd35f9016cb3f80341acf6319f301577
Author: Rajkumar Singh <ra...@hortonworks.com>
AuthorDate: Fri Mar 29 18:20:00 2019 -0700
HIVE-21342: Analyze compute stats for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus Camacho Rodriguez)
---
.../org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java
index 9aff006..89cc59e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java
@@ -278,6 +278,7 @@ public class ColumnStatsSemanticAnalyzer extends SemanticAnalyzer {
throw new SemanticException(ErrorMsg.COLUMNSTATSCOLLECTOR_IO_ERROR.getMsg());
}
ctx.setCmd(rewrittenQuery);
+ ctx.setHDFSCleanup(true);
try {
return ParseUtils.parse(rewrittenQuery, ctx);
@@ -374,6 +375,7 @@ public class ColumnStatsSemanticAnalyzer extends SemanticAnalyzer {
analyzeRewrite.setColName(colNames);
analyzeRewrite.setColType(colType);
qbp.setAnalyzeRewrite(analyzeRewrite);
+ origCtx.addRewrittenStatementContext(ctx);
initCtx(ctx);
ctx.setExplainConfig(origCtx.getExplainConfig());
LOG.info("Invoking analyze on rewritten query");