This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 4e63aa052c [fix](session-var) fix forward parallel fragment instance
num, and forward some session by the way (#23234)
4e63aa052c is described below
commit 4e63aa052c230c3ff34dd36dc187c273906e43f9
Author: Siyang Tang <[email protected]>
AuthorDate: Tue Aug 22 09:00:29 2023 +0800
[fix](session-var) fix forward parallel fragment instance num, and forward
some session by the way (#23234)
---
.../java/org/apache/doris/qe/SessionVariable.java | 23 +++++++++++-----------
1 file changed, 12 insertions(+), 11 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 b549cd507a..e9e89854d8 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
@@ -572,10 +572,10 @@ public class SessionVariable implements Serializable,
Writable {
* the parallel exec instance num for one Fragment in one BE
* 1 means disable this feature
*/
- @VariableMgr.VarAttr(name = PARALLEL_FRAGMENT_EXEC_INSTANCE_NUM, fuzzy =
true)
+ @VariableMgr.VarAttr(name = PARALLEL_FRAGMENT_EXEC_INSTANCE_NUM,
needForward = true, fuzzy = true)
public int parallelExecInstanceNum = 1;
- @VariableMgr.VarAttr(name = PARALLEL_PIPELINE_TASK_NUM, fuzzy = true)
+ @VariableMgr.VarAttr(name = PARALLEL_PIPELINE_TASK_NUM, fuzzy = true,
needForward = true)
public int parallelPipelineTaskNum = 0;
@VariableMgr.VarAttr(name = MAX_INSTANCE_NUM)
@@ -649,7 +649,8 @@ public class SessionVariable implements Serializable,
Writable {
@VariableMgr.VarAttr(name = ENABLE_VECTORIZED_ENGINE, varType =
VariableAnnotation.EXPERIMENTAL_ONLINE)
public boolean enableVectorizedEngine = true;
- @VariableMgr.VarAttr(name = ENABLE_PIPELINE_ENGINE, fuzzy = true, varType
= VariableAnnotation.EXPERIMENTAL)
+ @VariableMgr.VarAttr(name = ENABLE_PIPELINE_ENGINE, fuzzy = true,
needForward = true,
+ varType = VariableAnnotation.EXPERIMENTAL)
private boolean enablePipelineEngine = true;
@VariableMgr.VarAttr(name = ENABLE_PIPELINE_X_ENGINE, fuzzy = false,
varType = VariableAnnotation.EXPERIMENTAL)
@@ -683,29 +684,29 @@ public class SessionVariable implements Serializable,
Writable {
@VariableMgr.VarAttr(name = ENABLE_FOLD_CONSTANT_BY_BE, fuzzy = true)
private boolean enableFoldConstantByBe = false;
- @VariableMgr.VarAttr(name = RUNTIME_FILTER_MODE)
+ @VariableMgr.VarAttr(name = RUNTIME_FILTER_MODE, needForward = true)
private String runtimeFilterMode = "GLOBAL";
- @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_SIZE)
+ @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_SIZE, needForward = true)
private int runtimeBloomFilterSize = 2097152;
- @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_MIN_SIZE)
+ @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_MIN_SIZE, needForward =
true)
private int runtimeBloomFilterMinSize = 1048576;
- @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_MAX_SIZE)
+ @VariableMgr.VarAttr(name = RUNTIME_BLOOM_FILTER_MAX_SIZE, needForward =
true)
private int runtimeBloomFilterMaxSize = 16777216;
- @VariableMgr.VarAttr(name = RUNTIME_FILTER_WAIT_TIME_MS)
+ @VariableMgr.VarAttr(name = RUNTIME_FILTER_WAIT_TIME_MS, needForward =
true)
private int runtimeFilterWaitTimeMs = 1000;
- @VariableMgr.VarAttr(name = RUNTIME_FILTERS_MAX_NUM)
+ @VariableMgr.VarAttr(name = RUNTIME_FILTERS_MAX_NUM, needForward = true)
private int runtimeFiltersMaxNum = 10;
// Set runtimeFilterType to IN_OR_BLOOM filter
- @VariableMgr.VarAttr(name = RUNTIME_FILTER_TYPE, fuzzy = true)
+ @VariableMgr.VarAttr(name = RUNTIME_FILTER_TYPE, fuzzy = true, needForward
= true)
private int runtimeFilterType = 8;
- @VariableMgr.VarAttr(name = RUNTIME_FILTER_MAX_IN_NUM)
+ @VariableMgr.VarAttr(name = RUNTIME_FILTER_MAX_IN_NUM, needForward = true)
private int runtimeFilterMaxInNum = 1024;
@VariableMgr.VarAttr(name = USE_RF_DEFAULT)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
