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");