This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 2bd0ed6f0d1 [Chore](parallel-result-sink) disable fuzzy
ENABLE_PARALLEL_RESULT_SINK on branch-3.0 (#48068)
2bd0ed6f0d1 is described below
commit 2bd0ed6f0d1542d5f9950725048ba578130981ff
Author: Pxl <[email protected]>
AuthorDate: Tue Feb 25 14:20:07 2025 +0800
[Chore](parallel-result-sink) disable fuzzy ENABLE_PARALLEL_RESULT_SINK on
branch-3.0 (#48068)
### What problem does this PR solve?
disable fuzzy ENABLE_PARALLEL_RESULT_SINK on branch-3.0
related fix: https://github.com/apache/doris/pull/47915
---
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
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 d053369a4f2..0c303526cec 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
@@ -1217,7 +1217,7 @@ public class SessionVariable implements Serializable,
Writable {
@VariableMgr.VarAttr(name = ENABLE_SYNC_RUNTIME_FILTER_SIZE, needForward =
true)
private boolean enableSyncRuntimeFilterSize = true;
- @VariableMgr.VarAttr(name = ENABLE_PARALLEL_RESULT_SINK, needForward =
true, fuzzy = true)
+ @VariableMgr.VarAttr(name = ENABLE_PARALLEL_RESULT_SINK, needForward =
true, fuzzy = false)
private boolean enableParallelResultSink = false;
@VariableMgr.VarAttr(name = "sort_phase_num", fuzzy = true, needForward =
true,
@@ -2382,7 +2382,6 @@ public class SessionVariable implements Serializable,
Writable {
this.partitionedHashAggRowsThreshold = random.nextBoolean() ? 8 :
1048576;
this.enableShareHashTableForBroadcastJoin = random.nextBoolean();
// this.enableHashJoinEarlyStartProbe = random.nextBoolean();
- this.enableParallelResultSink = random.nextBoolean();
int randomInt = random.nextInt(4);
if (randomInt % 2 == 0) {
this.rewriteOrToInPredicateThreshold = 100000;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
