diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculatorV2.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculatorV2.java index 005e5963da..a3b97c01e3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculatorV2.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculatorV2.java @@ -331,6 +331,7 @@ public class StatsCalculatorV2 extends DefaultPlanVisitor childSlotToColumnStats = childStats.getSlotIdToColumnStats(); double resultSetCount = groupByExpressions.stream().flatMap(expr -> expr.getInputSlots().stream()) + .map(Slot::getExprId) .filter(childSlotToColumnStats::containsKey).map(childSlotToColumnStats::get).map(s -> s.ndv) .reduce(1d, (a, b) -> a * b); if (resultSetCount <= 0) {