fix

englefly · englefly · commit 863149bc50cf · 2024-05-22T14:35:52.000+08:00
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java
@@ -64,7 +64,7 @@ public List<PlanPostProcessor> getProcessors() {
         builder.add(new RecomputeLogicalPropertiesProcessor());
         builder.add(new AddOffsetIntoDistribute());
         builder.add(new CommonSubExpressionOpt());
-        if (!cascadesContext.getConnectContext().getSessionVariable().pushLimitToLocalAgg) {
+        if (cascadesContext.getConnectContext().getSessionVariable().pushLimitToLocalAgg) {
             builder.add(new PushLimitToLocalAgg());
         }
         // DO NOT replace PLAN NODE from here

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ public List<PlanPostProcessor> getProcessors() {`
`64`	`64`	`builder.add(new RecomputeLogicalPropertiesProcessor());`
`65`	`65`	`builder.add(new AddOffsetIntoDistribute());`
`66`	`66`	`builder.add(new CommonSubExpressionOpt());`
`67`		`- if (!cascadesContext.getConnectContext().getSessionVariable().pushLimitToLocalAgg) {`
	`67`	`+ if (cascadesContext.getConnectContext().getSessionVariable().pushLimitToLocalAgg) {`
`68`	`68`	`builder.add(new PushLimitToLocalAgg());`
`69`	`69`	`}`
`70`	`70`	`// DO NOT replace PLAN NODE from here`