fix

englefly · Nov 27, 2023 · 0c29e7c · 0c29e7c
1 parent 4d6d4af
commit 0c29e7c
Showing 1 changed file with 16 additions and 13 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
@@ -322,21 +322,24 @@ private double skewPenalty(PhysicalHashJoin<? extends Plan, ? extends Plan> phys
                                int totalInstanceNumber) {
         double penalty = 1.0;
         for (Expression conj : physicalHashJoin.getHashJoinConjuncts()) {
-            EqualTo eq = (EqualTo) JoinUtils.swapEqualToForChildrenOrder(
-                    (EqualTo) conj, physicalHashJoin.left().getOutputSet());
-            ColumnStatistic leftColStats = probeStats.findColumnStatistics(eq.left());
-            if (leftColStats != null && !leftColStats.isUnKnown()) {
-                if (leftColStats.ndv < beNumber) {
-                    penalty = Math.max(totalInstanceNumber / Math.max(1.0, leftColStats.ndv), penalty);
-                    break;
+            // TODO: NullSafeEqualTo need refactor
+            if (conj instanceof EqualTo) {
+                EqualTo eq = (EqualTo) JoinUtils.swapEqualToForChildrenOrder(
+                        (EqualTo) conj, physicalHashJoin.left().getOutputSet());
+                ColumnStatistic leftColStats = probeStats.findColumnStatistics(eq.left());
+                if (leftColStats != null && !leftColStats.isUnKnown()) {
+                    if (leftColStats.ndv < beNumber) {
+                        penalty = Math.max(totalInstanceNumber / Math.max(1.0, leftColStats.ndv), penalty);
+                        break;
+                    }
                 }
-            }
 
-            ColumnStatistic rightColStats = buildStats.findColumnStatistics(eq.right());
-            if (rightColStats != null && !rightColStats.isUnKnown()) {
-                if (rightColStats.ndv < beNumber) {
-                    penalty = Math.max(totalInstanceNumber / Math.max(1.0, rightColStats.ndv), penalty);
-                    break;
+                ColumnStatistic rightColStats = buildStats.findColumnStatistics(eq.right());
+                if (rightColStats != null && !rightColStats.isUnKnown()) {
+                    if (rightColStats.ndv < beNumber) {
+                        penalty = Math.max(totalInstanceNumber / Math.max(1.0, rightColStats.ndv), penalty);
+                        break;
+                    }
                 }
             }
         }