diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/PushDownAggregation.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/PushDownAggregation.java index d92bc91e61ce20..678824f8982a03 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/PushDownAggregation.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/PushDownAggregation.java @@ -35,7 +35,6 @@ package org.apache.doris.nereids.rules.rewrite.eageraggregation; import org.apache.doris.nereids.jobs.JobContext; -import org.apache.doris.nereids.rules.analysis.NormalizeAggregate; import org.apache.doris.nereids.rules.rewrite.AdjustNullable; import org.apache.doris.nereids.trees.expressions.CaseWhen; import org.apache.doris.nereids.trees.expressions.Expression; @@ -75,7 +74,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.Optional; import java.util.Set; import java.util.stream.Collectors; @@ -274,11 +272,12 @@ public Plan visitLogicalAggregate(LogicalAggregate agg, JobConte newOutputExpressions.add(replaceAliasExpr); } } - LogicalAggregate eagerAgg = - agg.withAggOutputChild(newOutputExpressions, child); - NormalizeAggregate normalizeAggregate = new NormalizeAggregate(); - return normalizeAggregate.normalizeAgg(eagerAgg, Optional.empty(), - context.getCascadesContext()); + return agg.withAggOutputChild(newOutputExpressions, child); + // LogicalAggregate eagerAgg = + // agg.withAggOutputChild(newOutputExpressions, child); + // NormalizeAggregate normalizeAggregate = new NormalizeAggregate(); + // return normalizeAggregate.normalizeAgg(eagerAgg, Optional.empty(), + // context.getCascadesContext()); } } catch (RuntimeException e) { String msg = "PushDownAggregation failed: " + e.getMessage() + "\n" + agg.treeString();