diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/reloperators/HiveAggregate.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/reloperators/HiveAggregate.java index dc6b152dda..7448c37d38 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/reloperators/HiveAggregate.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/reloperators/HiveAggregate.java @@ -76,7 +76,7 @@ public double estimateRowCount(RelMetadataQuery mq) { } public boolean isBucketedInput() { - return RelMetadataQuery.instance().distribution(this.getInput()).getKeys(). + return RelMetadataQuery.instance().distribution(this).getKeys(). containsAll(groupSet.asList()); }