database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](fuzzy)nereids and pipeline config changed by fuzzy in non-pipeline env. (#21092)

Browse Source 
* fix: nereids and pipeline config  changed by fuzzy in non-pipeline env.

* fix: format

* fix: format
This commit is contained in:
shuke
2023-06-22 08:36:19 +08:00
committed by GitHub
parent a33521b2ce
commit 9f0aa8a9de
1 changed files with 32 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
View File

@ -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;
}
}
}