You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2023/06/22 00:36:28 UTC
[doris] branch master updated: [fix](fuzzy)nereids and pipeline config changed by fuzzy in non-pipeline env. (#21092)
This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 9f0aa8a9de [fix](fuzzy)nereids and pipeline config changed by fuzzy in non-pipeline env. (#21092)
9f0aa8a9de is described below
commit 9f0aa8a9de022db397e4c27650789e986e5aeb92
Author: shuke <37...@users.noreply.github.com>
AuthorDate: Thu Jun 22 08:36:19 2023 +0800
[fix](fuzzy)nereids and pipeline config changed by fuzzy in non-pipeline env. (#21092)
* fix: nereids and pipeline config changed by fuzzy in non-pipeline env.
* fix: format
* fix: format
---
.../java/org/apache/doris/qe/SessionVariable.java | 60 ++++++++++++----------
1 file changed, 32 insertions(+), 28 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 c0e243f7d2..bb72439de8 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
@@ -1020,37 +1020,41 @@ public class SessionVariable implements Serializable, Writable {
this.externalAggPartitionBits = 4;
break;
}
- // pull_request_id default value is 0
- switch (Config.pull_request_id % 4) {
- case 0:
- this.enablePipelineEngine = true;
- this.runtimeFilterType |= TRuntimeFilterType.BITMAP.getValue();
- this.enableNereidsPlanner = true;
- break;
- case 1:
- this.enablePipelineEngine = true;
- this.runtimeFilterType |= TRuntimeFilterType.BITMAP.getValue();
- this.enableNereidsPlanner = false;
- break;
- case 2:
- this.enablePipelineEngine = false;
- this.runtimeFilterType &= ~TRuntimeFilterType.BITMAP.getValue();
- this.enableNereidsPlanner = true;
- break;
- case 3:
- this.enablePipelineEngine = false;
- this.runtimeFilterType &= ~TRuntimeFilterType.BITMAP.getValue();
- this.enableNereidsPlanner = false;
- break;
- default:
- break;
+ // pull_request_id default value is 0. When it is 0, use default (global) session variable.
+ if (Config.pull_request_id > 0) {
+ switch (Config.pull_request_id % 4) {
+ case 0:
+ this.enablePipelineEngine = true;
+ this.runtimeFilterType |= TRuntimeFilterType.BITMAP.getValue();
+ this.enableNereidsPlanner = true;
+ break;
+ case 1:
+ this.enablePipelineEngine = true;
+ this.runtimeFilterType |= TRuntimeFilterType.BITMAP.getValue();
+ this.enableNereidsPlanner = false;
+ break;
+ case 2:
+ this.enablePipelineEngine = false;
+ this.runtimeFilterType &= ~TRuntimeFilterType.BITMAP.getValue();
+ this.enableNereidsPlanner = true;
+ break;
+ case 3:
+ this.enablePipelineEngine = false;
+ this.runtimeFilterType &= ~TRuntimeFilterType.BITMAP.getValue();
+ this.enableNereidsPlanner = false;
+ break;
+ default:
+ break;
+ }
}
if (Config.fuzzy_test_type.equals("p0")) {
- if (Config.pull_request_id % 2 == 1) {
- this.batchSize = 4064;
- } else {
- this.batchSize = 50;
+ if (Config.pull_request_id > 0) {
+ if (Config.pull_request_id % 2 == 1) {
+ this.batchSize = 4064;
+ } else {
+ this.batchSize = 50;
+ }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org