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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
