[doris] branch master updated: [fix](Nereids) finalize local aggregate should not turn on stream pre agg (#13922)

[morrysnow]

This is an automated email from the ASF dual-hosted git repository.

morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 31d8fdd9e4 [fix](Nereids) finalize local aggregate should not turn on 
stream pre agg (#13922)
31d8fdd9e4 is described below

commit 31d8fdd9e4e3345da3ace066892747f4e263cea3
Author: morrySnow <101034200+morrys...@users.noreply.github.com>
AuthorDate: Thu Nov 3 11:08:06 2022 +0800

    [fix](Nereids) finalize local aggregate should not turn on stream pre agg 
(#13922)
---
 .../nereids/rules/implementation/LogicalAggToPhysicalHashAgg.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalAggToPhysicalHashAgg.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalAggToPhysicalHashAgg.java
index f6672aa7ee..46874ff526 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalAggToPhysicalHashAgg.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalAggToPhysicalHashAgg.java
@@ -29,7 +29,8 @@ public class LogicalAggToPhysicalHashAgg extends 
OneImplementationRuleFactory {
     public Rule build() {
         return logicalAggregate().thenApply(ctx -> {
             boolean useStreamAgg = 
!ctx.connectContext.getSessionVariable().disableStreamPreaggregations
-                    && !ctx.root.getGroupByExpressions().isEmpty();
+                    && !ctx.root.getGroupByExpressions().isEmpty()
+                    && !ctx.root.isFinalPhase();
             return new PhysicalAggregate<>(
                     ctx.root.getGroupByExpressions(),
                     ctx.root.getOutputExpressions(),


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org