diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java index a53bd61d8facf4c..f92f479dc088b34 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java @@ -244,7 +244,7 @@ public Plan planWithLock(LogicalPlan plan, PhysicalProperties requireProperties, */ private void setRuntimeFilterWaitTimeByTableRowCountAndType() { if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable().getRuntimeFilterWaitTimeMs() - != VariableMgr.getDefaultSessionVariable().runtimeFilterWaitTimeMs) { + != VariableMgr.getDefaultSessionVariable().getRuntimeFilterWaitTimeMs()) { List scans = cascadesContext.getRewritePlan() .collectToList(LogicalCatalogRelation.class::isInstance); double maxRow = StatsCalculator.getMaxTableRowCount(scans, cascadesContext); diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index b626709d161af0e..67a4b32aea8c474 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -1162,7 +1162,7 @@ public enum IgnoreSplitType { private int runtimeBloomFilterMaxSize = 16777216; @VariableMgr.VarAttr(name = RUNTIME_FILTER_WAIT_TIME_MS, needForward = true) - public int runtimeFilterWaitTimeMs = 1000; + private int runtimeFilterWaitTimeMs = 1000; @VariableMgr.VarAttr(name = runtime_filter_wait_infinitely, needForward = true) private boolean runtimeFilterWaitInfinitely = false;