From 386a4a0b431efd67877519cb1eb06ebee51fd3cf Mon Sep 17 00:00:00 2001 From: minghong Date: Fri, 2 Jun 2023 17:13:09 +0800 Subject: [PATCH] [fix](nereids) add fragment id on all PhysicalRelation (#20371) fix "cannot find fragment id for scan" exception --- .../doris/nereids/processor/post/FragmentProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/FragmentProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/FragmentProcessor.java index ddc0e76067..e07b72b2f7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/FragmentProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/FragmentProcessor.java @@ -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; }