diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java index 465d110..2c2a4fd 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java @@ -25,7 +25,6 @@ import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.ql.ErrorMsg; -import org.apache.hadoop.hive.ql.exec.AppMasterEventOperator; import org.apache.hadoop.hive.ql.exec.ColumnInfo; import org.apache.hadoop.hive.ql.exec.CommonJoinOperator; import org.apache.hadoop.hive.ql.exec.FilterOperator; @@ -630,8 +629,7 @@ public Object process(Node nd, Stack stack, NodeProcessorCtx procCtx, // Case 8: column stats, grouping sets — Min(numRows, ndvProduct * sizeOfGroupingSet) // Case 9: column stats, NO grouping sets - Min(numRows, ndvProduct) - if (gop.getChildOperators().get(0) instanceof ReduceSinkOperator || - gop.getChildOperators().get(0) instanceof AppMasterEventOperator) { + if (gop.getConf().getMode().equals(GroupByDesc.Mode.MERGEPARTIAL) == false) { mapSide = true;