Skip to content

Commit

Permalink
wait back to private
Browse files Browse the repository at this point in the history
  • Loading branch information
englefly committed Nov 6, 2024
1 parent ef31f04 commit 4a0ed88
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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<LogicalCatalogRelation> scans = cascadesContext.getRewritePlan()
.collectToList(LogicalCatalogRelation.class::isInstance);
double maxRow = StatsCalculator.getMaxTableRowCount(scans, cascadesContext);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 4a0ed88

Please sign in to comment.