diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalIntersect.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalIntersect.java index 06f0f7d0ce6c4e..610a40ac96af3c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalIntersect.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalIntersect.java @@ -107,9 +107,7 @@ public LogicalIntersect withNewOutputs(List newOutputs) { Map constructReplaceMap() { Map replaceMap = new HashMap<>(); for (int i = 0; i < children.size(); i++) { - List originOutputs = this.regularChildrenOutputs.size() == children.size() - ? child(i).getOutput() - : regularChildrenOutputs.get(i); + List originOutputs = regularChildrenOutputs.get(i); for (int j = 0; j < originOutputs.size(); j++) { replaceMap.put(originOutputs.get(j), getOutput().get(j)); } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalIntersect.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalIntersect.java index 3194939a9e6481..e05763442ccc4f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalIntersect.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalIntersect.java @@ -118,9 +118,7 @@ public PhysicalIntersect resetLogicalProperties() { Map constructReplaceMap() { Map replaceMap = new HashMap<>(); for (int i = 0; i < children.size(); i++) { - List originOutputs = this.regularChildrenOutputs.size() == children.size() - ? child(i).getOutput() - : regularChildrenOutputs.get(i); + List originOutputs = regularChildrenOutputs.get(i); for (int j = 0; j < originOutputs.size(); j++) { replaceMap.put(originOutputs.get(j), getOutput().get(j)); }