From 4a0ed8819ecbca5b09fa64ae90473bd761d8bebb Mon Sep 17 00:00:00 2001 From: minghong Date: Wed, 6 Nov 2024 09:35:57 +0800 Subject: [PATCH] wait back to private --- .../src/main/java/org/apache/doris/nereids/NereidsPlanner.java | 2 +- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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;