You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by en...@apache.org on 2023/06/19 15:42:09 UTC
[doris] branch master updated: [fix](nereids)distribute node missing rows and cost #20943
This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new be8fb68712 [fix](nereids)distribute node missing rows and cost #20943
be8fb68712 is described below
commit be8fb687122ae823402ee2dec348f253399bb0fb
Author: minghong <en...@gmail.com>
AuthorDate: Mon Jun 19 23:42:01 2023 +0800
[fix](nereids)distribute node missing rows and cost #20943
in dumped memo, distribute node missed estimated rows and cost.
---
.../doris/nereids/properties/EnforceMissingPropertiesHelper.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/properties/EnforceMissingPropertiesHelper.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/properties/EnforceMissingPropertiesHelper.java
index d99f14efd0..6ea0f9f064 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/properties/EnforceMissingPropertiesHelper.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/properties/EnforceMissingPropertiesHelper.java
@@ -154,10 +154,13 @@ public class EnforceMissingPropertiesHelper {
oldOutputProperty, newOutputProperty);
ENFORCER_TRACER.log(EnforcerEvent.of(groupExpression, ((PhysicalPlan) enforcer.getPlan()),
oldOutputProperty, newOutputProperty));
+ enforcer.setEstOutputRowCount(enforcer.getOwnerGroup().getStatistics().getRowCount());
+ Cost enforcerCost = CostCalculator.calculateCost(enforcer, Lists.newArrayList(oldOutputProperty));
+ enforcer.setCost(enforcerCost.getValue());
curTotalCost = CostCalculator.addChildCost(enforcer.getPlan(),
- CostCalculator.calculateCost(enforcer, Lists.newArrayList(oldOutputProperty)),
- curTotalCost,
- 0);
+ enforcerCost,
+ curTotalCost,
+ 0);
if (enforcer.updateLowestCostTable(newOutputProperty,
Lists.newArrayList(oldOutputProperty), curTotalCost)) {
enforcer.putOutputPropertiesMap(newOutputProperty, newOutputProperty);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org