database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[opt](Nereids) enable parallel scan for local phase agg (#21642)

Browse Source 
after we forbid some cases off agg candidate plans,
all local phase agg require DistributionSpecAny for child.
So, we could enable parallel scan for it
This commit is contained in:
morrySnow
2023-07-08 21:47:17 +08:00
committed by GitHub
parent 7caab87bbe
commit aad8043d44
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
View File

@ -699,8 +699,11 @@ public class PhysicalPlanTranslator extends DefaultPlanVisitor<PlanFragment, Pla
// TODO: nereids forbid all parallel scan under aggregate temporary, because nereids could generate
// so complex aggregate plan than legacy planner, and should add forbid parallel scan hint when
// 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) {
&& inputPlanFragment.getDataPartition().getType() != TPartitionType.RANDOM
&& aggregate.getAggregateParam().aggMode != AggMode.INPUT_TO_BUFFER) {
inputPlanFragment.setHasColocatePlanNode(true);
}
setPlanRoot(inputPlanFragment, aggregationNode, aggregate);