From 3d2c70f75d9e262a80e74945aee03d541bd8fc87 Mon Sep 17 00:00:00 2001 From: jakevin Date: Thu, 30 Mar 2023 20:34:47 +0800 Subject: [PATCH] [fix](Nereids): fix merge_group(). (#18250) --- .../src/main/java/org/apache/doris/nereids/memo/Memo.java | 4 +--- 1 file changed, 1 insertion(+), 3 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 724b91bb97..078ddf72f6 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 @@ -451,7 +451,6 @@ public class Memo { } GROUP_MERGE_TRACER.log(GroupMergeEvent.of(source, destination, needReplaceChild)); - Map needMergeGroupPairs = Maps.newHashMap(); for (GroupExpression reinsertGroupExpr : needReplaceChild) { // After change GroupExpression children, hashcode will change, so need to reinsert into map. groupExpressions.remove(reinsertGroupExpr); @@ -472,7 +471,7 @@ public class Memo { reinsertGroupExpr.mergeTo(existGroupExpr); } else { // reinsertGroupExpr & existGroupExpr aren't in same group, need to merge their OwnerGroup. - needMergeGroupPairs.put(reinsertGroupExpr.getOwnerGroup(), existGroupExpr.getOwnerGroup()); + mergeGroup(reinsertGroupExpr.getOwnerGroup(), existGroupExpr.getOwnerGroup()); } } else { groupExpressions.put(reinsertGroupExpr, reinsertGroupExpr); @@ -483,7 +482,6 @@ public class Memo { groups.remove(source.getGroupId()); } - needMergeGroupPairs.forEach(this::mergeGroup); return destination; }