From dbc183b72f462dbf89447f155e041b1f9d5daa00 Mon Sep 17 00:00:00 2001 From: Ashutosh Chauhan Date: Wed, 2 May 2018 21:34:18 -0700 Subject: [PATCH] HIVE-19396 : HiveOperation is incorrectly set for analyze statement --- .../apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 2780be2518..7cb17241db 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 @@ -35,6 +35,7 @@ import org.apache.hadoop.hive.ql.exec.Utilities; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.ql.metadata.Table; +import org.apache.hadoop.hive.ql.plan.HiveOperation; import org.apache.hadoop.hive.ql.session.SessionState; import org.apache.hadoop.hive.ql.session.SessionState.LogHelper; import org.apache.hadoop.hive.serde.serdeConstants; @@ -236,7 +237,7 @@ private String getColTypeOf(String partKey) throws SemanticException{ } } } - + return colTypes; } @@ -403,6 +404,9 @@ public void analyze(ASTNode ast, Context origCtx) throws SemanticException { ctx.setExplainConfig(origCtx.getExplainConfig()); LOG.info("Invoking analyze on rewritten query"); analyzeInternal(rewrittenTree); + // After analyzeInternal() Hiveop get set as Query + // since we are passing in AST for select query, so reset it. + this.queryState.setCommandType(HiveOperation.ANALYZE_TABLE); } else { initCtx(origCtx); LOG.info("Invoking analyze on original query"); -- 2.15.1 (Apple Git-101)