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:22:23 UTC
[hive] branch branch-3.1 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.1
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new cf9bf8f HIVE-21342: Analyze compute stats for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus Camacho Rodriguez)
cf9bf8f is described below
commit cf9bf8f0420ae849b03ca03a698aceba8a126cd0
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");