diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/batch/NereidsRewriter.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/batch/NereidsRewriter.java index 2509c114c4..4668a771cb 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/batch/NereidsRewriter.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/batch/NereidsRewriter.java @@ -150,15 +150,15 @@ public class NereidsRewriter extends BatchRewriteJob { ), topic("Window analysis", + topDown( + new SimplifyAggGroupBy() + ), topDown( new ExtractAndNormalizeWindowExpression(), // execute NormalizeAggregate() again to resolve nested AggregateFunctions in WindowExpression, // e.g. sum(sum(c1)) over(partition by avg(c1)) new NormalizeAggregate(), new CheckAndStandardizeWindowFunctionAndFrame() - ), - topDown( - new SimplifyAggGroupBy() ) ),