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

[fix](nereids) add fragment id on all PhysicalRelation (#20371)

Browse Source 
fix "cannot find fragment id for scan" exception
This commit is contained in:
minghong
2023-06-02 17:13:09 +08:00
committed by GitHub
parent 78c37b5244
commit 386a4a0b43
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/FragmentProcessor.java
View File

@ -22,7 +22,7 @@ import org.apache.doris.nereids.trees.plans.AbstractPlan;
import org.apache.doris.nereids.trees.plans.Plan;
import org.apache.doris.nereids.trees.plans.physical.PhysicalDistribute;
import org.apache.doris.nereids.trees.plans.physical.PhysicalHashJoin;
import org.apache.doris.nereids.trees.plans.physical.PhysicalOlapScan;
import org.apache.doris.nereids.trees.plans.physical.PhysicalRelation;
/**
* generate fragment id for nereids physical plan
@ -45,7 +45,7 @@ public class FragmentProcessor extends PlanPostProcessor {
return join;
}
public PhysicalOlapScan visitPhysicalOlapScan(PhysicalOlapScan scan, CascadesContext ctx) {
public PhysicalRelation visitPhysicalScan(PhysicalRelation scan, CascadesContext ctx) {
scan.setMutableState(AbstractPlan.FRAGMENT_ID, frId);
return scan;
}