From 168742deba6ffe4cb4d217715dec879153801f08 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Fri, 13 Sep 2024 22:46:31 +0800 Subject: [PATCH] [followup](branch-2.1) Fuzzy `parallel_prepare_threshold` (#40793) ## Proposed changes Issue Number: close #xxx --- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 9b970ad80d..e1b398335b 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 @@ -1046,7 +1046,7 @@ public class SessionVariable implements Serializable, Writable { @VariableMgr.VarAttr(name = AUTO_BROADCAST_JOIN_THRESHOLD) public double autoBroadcastJoinThreshold = 0.8; - @VariableMgr.VarAttr(name = PARALLEL_PREPARE_THRESHOLD) + @VariableMgr.VarAttr(name = PARALLEL_PREPARE_THRESHOLD, fuzzy = true) public int parallelPrepareThreshold = 32; @VariableMgr.VarAttr(name = ENABLE_COST_BASED_JOIN_REORDER) @@ -2086,6 +2086,7 @@ public class SessionVariable implements Serializable, Writable { Random random = new SecureRandom(); this.parallelExecInstanceNum = random.nextInt(8) + 1; this.parallelPipelineTaskNum = random.nextInt(8); + this.parallelPrepareThreshold = random.nextInt(32) + 1; this.enableCommonExprPushdown = random.nextBoolean(); this.enableLocalExchange = random.nextBoolean(); // This will cause be dead loop, disable it first