diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java index 386fed6..d41e966 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java @@ -707,6 +707,10 @@ private boolean validateAggregationDesc(AggregationDesc aggDesc) { if (!supportedAggregationUdfs.contains(aggDesc.getGenericUDAFName().toLowerCase())) { return false; } + if (aggDesc.getDistinct() && + !aggDesc.getGenericUDAFName().equalsIgnoreCase("count")) { + return false; + } if (aggDesc.getParameters() != null) { return validateExprNodeDesc(aggDesc.getParameters()); }