diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java index 0a1ae85adfe803..c0110a88ef7f90 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java @@ -133,6 +133,7 @@ import org.apache.doris.nereids.types.DataType; import org.apache.doris.nereids.util.PlanUtils; import org.apache.doris.qe.ConnectContext; +import org.apache.doris.qe.SessionVariable; import org.apache.doris.statistics.AnalysisManager; import org.apache.doris.statistics.ColumnStatistic; import org.apache.doris.statistics.ColumnStatisticBuilder; @@ -362,8 +363,14 @@ public static Optional disableJoinReorderIfStatsInvalid(List disableJoinReorderIfStatsInvalid(List reason = calculator.checkNdvValidation((OlapScan) scan, rowCount); if (reason.isPresent()) { try { - ConnectContext.get().getSessionVariable().disableNereidsJoinReorderOnce(); + ConnectContext.get().getSessionVariable() + .setVarOnce(SessionVariable.DISABLE_JOIN_REORDER, "true"); LOG.info("disable join reorder since col stats invalid: " + reason.get()); } catch (Exception e) {