diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/joinorder/hypergraph/receiver/PlanReceiver.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/joinorder/hypergraph/receiver/PlanReceiver.java index be7e462b49867b..8023d806da7abe 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/joinorder/hypergraph/receiver/PlanReceiver.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/joinorder/hypergraph/receiver/PlanReceiver.java @@ -306,7 +306,7 @@ private void makeLogicalExpression(Group root) { } hasGenerated.add(groupExpression); - // process child first + // process child first, plan's child may be changed due to mergeGroup Plan physicalPlan = groupExpression.getPlan(); for (Group child : groupExpression.children()) { makeLogicalExpression(child); @@ -316,12 +316,12 @@ private void makeLogicalExpression(Group root) { if (physicalPlan instanceof PhysicalProject) { PhysicalProject physicalProject = (PhysicalProject) physicalPlan; logicalPlan = new LogicalProject<>(physicalProject.getProjects(), - physicalProject.child(0)); + new GroupPlan(groupExpression.child(0))); } else if (physicalPlan instanceof AbstractPhysicalJoin) { AbstractPhysicalJoin physicalJoin = (AbstractPhysicalJoin) physicalPlan; logicalPlan = new LogicalJoin<>(physicalJoin.getJoinType(), physicalJoin.getHashJoinConjuncts(), physicalJoin.getOtherJoinConjuncts(), JoinHint.NONE, physicalJoin.getMarkJoinSlotReference(), - physicalJoin.children()); + groupExpression.children().stream().map(g -> new GroupPlan(g)).collect(Collectors.toList())); } else { throw new RuntimeException("DPhyp can only handle join and project operator"); }