This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 501270d99e5 [Chore](fuzzy) enable some fuzzy variables (#38155)
501270d99e5 is described below
commit 501270d99e5652ce41851186f894aa83fcc89f3f
Author: Pxl <[email protected]>
AuthorDate: Wed Jul 24 15:44:24 2024 +0800
[Chore](fuzzy) enable some fuzzy variables (#38155)
## Proposed changes
enable fuzzy topnOptLimitThreshold, runtimeFilterMaxInNum,
runtimeFilterWaitTimeMs, enableSyncRuntimeFilterSize
---
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 7 +++++++
1 file changed, 7 insertions(+)
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 12455e31c76..32212ca9d45 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
@@ -2113,10 +2113,14 @@ public class SessionVariable implements Serializable,
Writable {
this.rewriteOrToInPredicateThreshold = 100000;
this.enableFunctionPushdown = false;
this.enableDeleteSubPredicateV2 = false;
+ this.topnOptLimitThreshold = 0;
+ this.enableSyncRuntimeFilterSize = true;
} else {
this.rewriteOrToInPredicateThreshold = 2;
this.enableFunctionPushdown = true;
this.enableDeleteSubPredicateV2 = true;
+ this.topnOptLimitThreshold = 1024;
+ this.enableSyncRuntimeFilterSize = false;
}
/*
@@ -2166,6 +2170,7 @@ public class SessionVariable implements Serializable,
Writable {
switch (Config.pull_request_id % 3) {
case 0:
this.fragmentTransmissionCompressionCodec = "snappy";
+ this.runtimeFilterWaitTimeMs = 10;
break;
case 1:
this.fragmentTransmissionCompressionCodec = "lz4";
@@ -2180,10 +2185,12 @@ public class SessionVariable implements Serializable,
Writable {
case 0:
this.parallelScanMaxScannersCount = 32;
this.parallelScanMinRowsPerScanner = 64;
+ this.runtimeFilterMaxInNum = 10;
break;
case 1:
this.parallelScanMaxScannersCount = 16;
this.parallelScanMinRowsPerScanner = 128;
+ this.runtimeFilterMaxInNum = 0;
break;
case 2:
this.parallelScanMaxScannersCount = 8;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
