[hive] branch master updated: HIVE-21342: Analyze compute stats for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus Camacho Rodriguez)

[jc...@apache.org]

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

jcamacho 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 6f18bbb  HIVE-21342: Analyze compute stats for column leave behind staging dir on hdfs (Rajkumar Singh via Jesus Camacho Rodriguez)
6f18bbb is described below

commit 6f18bbbc2e030ce7d446b2475037203cbd4f860d
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 066807b..35f7ec6 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
@@ -312,6 +312,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);
@@ -408,6 +409,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");