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 066807b2d0..84625c2f9f 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 @@ private ASTNode genRewrittenTree(String rewrittenQuery) throws SemanticException throw new SemanticException(ErrorMsg.COLUMNSTATSCOLLECTOR_IO_ERROR.getMsg()); } ctx.setCmd(rewrittenQuery); + ctx.setHDFSCleanup(true); try { return ParseUtils.parse(rewrittenQuery, ctx); @@ -390,6 +391,7 @@ public void analyze(ASTNode ast, Context origCtx) throws SemanticException { colType = getColumnTypes(tbl, colNames); rewrittenQuery = genRewrittenQuery(colNames, conf, partSpec, isPartitionStats, false); rewrittenTree = genRewrittenTree(rewrittenQuery); + origCtx.addRewrittenStatementContext(ctx); } else { // Not an analyze table column compute statistics statement - don't do any rewrites originalTree = rewrittenTree = ast;