adjust agg cost

englefly · Aug 9, 2024 · 0520b2f · 0520b2f
1 parent 547ff3c
commit 0520b2f
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/cost/CostModelV1.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/cost/CostModelV1.java
@@ -329,14 +329,16 @@ public Cost visitPhysicalHashAggregate(
             PhysicalHashAggregate<? extends Plan> aggregate, PlanContext context) {
         Statistics inputStatistics = context.getChildStatistics(0);
         double exprCost = expressionTreeCost(aggregate.getExpressions());
+        double aggCostBaseFactor = 3;
         if (aggregate.getAggPhase().isLocal()) {
             return CostV1.of(context.getSessionVariable(),
-                    exprCost / 100 + inputStatistics.getRowCount() / beNumber,
-                    inputStatistics.getRowCount() / beNumber, 0);
+                    exprCost / 100 + aggCostBaseFactor * inputStatistics.getRowCount() / beNumber,
+                    aggCostBaseFactor * inputStatistics.getRowCount() / beNumber, 0);
         } else {
             // global
-            return CostV1.of(context.getSessionVariable(), exprCost / 100 + inputStatistics.getRowCount(),
-                    inputStatistics.getRowCount(), 0);
+            return CostV1.of(context.getSessionVariable(), exprCost / 100
+                            + aggCostBaseFactor * inputStatistics.getRowCount(),
+                    aggCostBaseFactor * inputStatistics.getRowCount(), 0);
         }
     }