From 93089264cbe8beb695edd59ae7fa1a6ed93e970a Mon Sep 17 00:00:00 2001 From: Gabriel Date: Fri, 13 Sep 2024 13:56:48 +0800 Subject: [PATCH] [followup](branch-2.1) Fuzzy `parallel_prepare_threshold` --- .../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 9b970ad80d49d0..e1b398335b9b2d 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 void initFuzzyModeVariables() { 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