This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9f14fc435b746e51d21730af23a1935e8769a74a Author: 谢健 <[email protected]> AuthorDate: Sat Aug 5 12:19:28 2023 +0800 fix join count (#22619) --- fe/fe-core/src/main/java/org/apache/doris/nereids/memo/Memo.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/memo/Memo.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/memo/Memo.java index 67534014ce..33242b013a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/memo/Memo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/memo/Memo.java @@ -31,6 +31,7 @@ import org.apache.doris.nereids.trees.expressions.Expression; import org.apache.doris.nereids.trees.plans.GroupPlan; import org.apache.doris.nereids.trees.plans.LeafPlan; import org.apache.doris.nereids.trees.plans.Plan; +import org.apache.doris.nereids.trees.plans.logical.LogicalJoin; import org.apache.doris.nereids.trees.plans.logical.LogicalPlan; import org.apache.doris.nereids.trees.plans.logical.LogicalProject; import org.apache.doris.nereids.trees.plans.physical.PhysicalDistribute; @@ -48,7 +49,6 @@ import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map; -import java.util.Map.Entry; import java.util.Optional; import java.util.PriorityQueue; import java.util.stream.Collectors; @@ -187,7 +187,7 @@ public class Memo { for (Pair<Integer, Integer> child : children) { maxJoinCount = Math.max(maxJoinCount, child.second); } - if (group.isValidJoinGroup()) { + if (group.getLogicalExpression().getPlan() instanceof LogicalJoin) { for (Pair<Integer, Integer> child : children) { continuousJoinCount += child.first; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
