diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MergeAggregate.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MergeAggregate.java index a2c23dd9b412b0..8ea8a7f217dbc3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MergeAggregate.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MergeAggregate.java @@ -146,7 +146,7 @@ boolean commonCheck(LogicalAggregate outerAgg, LogicalAggregate< (existValue, newValue) -> existValue)); Set aggregateFunctions = outerAgg.getAggregateFunctions(); List replacedAggFunctions = projectOptional.map(project -> - (List) PlanUtils.replaceExpressionByProjections( + (List) (List) PlanUtils.replaceExpressionByProjections( projectOptional.get().getProjects(), new ArrayList<>(aggregateFunctions))) .orElse(new ArrayList<>(aggregateFunctions)); for (AggregateFunction outerFunc : replacedAggFunctions) {