This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 6df59c37536 [fix](nereids) fix aggr node colocate flag local shuffle
depending on (#37789)
6df59c37536 is described below
commit 6df59c375366078824d6d7bfb7796e94072dab81
Author: xzj7019 <[email protected]>
AuthorDate: Mon Jul 15 13:17:02 2024 +0800
[fix](nereids) fix aggr node colocate flag local shuffle depending on
(#37789)
## Proposed changes
pick from https://github.com/apache/doris/pull/37788
Co-authored-by: zhongjian.xzj
<[email protected]>
---
.../apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
index e02b18ce849..db799436b0a 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -1050,9 +1050,7 @@ public class PhysicalPlanTranslator extends
DefaultPlanVisitor<PlanFragment, Pla
// generate physical aggregate plan.
// There is one exception, we use some precondition in optimizer,
input to buffer always require any for input,
// so when agg mode is INPUT_TO_BUFFER, we do not forbid parallel scan
- if (leftMostNode instanceof OlapScanNode
- && inputPlanFragment.getDataPartition().getType() !=
TPartitionType.RANDOM
- && aggregate.getAggregateParam().aggMode !=
AggMode.INPUT_TO_BUFFER) {
+ if (aggregate.getAggregateParam().aggMode != AggMode.INPUT_TO_BUFFER) {
inputPlanFragment.setHasColocatePlanNode(true);
// Set colocate info in agg node. This is a hint for local
shuffling to decide which type of
// local exchanger will be used.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
