This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new bdd337cc9c4 [opt](Nereids) add switch to control whether use pipeline
in DML (#35728)
bdd337cc9c4 is described below
commit bdd337cc9c4c8ac08e19ac1da3822800da8960bb
Author: morrySnow <[email protected]>
AuthorDate: Fri May 31 19:00:14 2024 +0800
[opt](Nereids) add switch to control whether use pipeline in DML (#35728)
pick from master #28037
commit id 1aa1b2f60749beb5db329d0b2a27156fc46cd9de
to turn on pipeline for DML in Nerieds, please:
set enable_nereids_dml_with_pipeline = true;
---
.../apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java | 3 +++
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 5 +++++
2 files changed, 8 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java
index 79afe5d2ead..8fff31ac743 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java
@@ -47,6 +47,9 @@ public class TurnOffPipelineForDml extends PlanPreprocessor {
private void turnOffPipeline(StatementContext context) {
SessionVariable sessionVariable =
context.getConnectContext().getSessionVariable();
+ if (sessionVariable.enableNereidsDmlWithPipeline) {
+ return;
+ }
// set temporary session value, and then revert value in the 'finally
block' of StmtExecutor#execute
sessionVariable.setIsSingleSetVar(true);
try {
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 840603dc3ff..e30796f326b 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
@@ -189,6 +189,7 @@ public class SessionVariable implements Serializable,
Writable {
public static final String MAX_JOIN_NUMBER_OF_REORDER =
"max_join_number_of_reorder";
public static final String ENABLE_NEREIDS_DML = "enable_nereids_dml";
+ public static final String ENABLE_NEREIDS_DML_WITH_PIPELINE =
"enable_nereids_dml_with_pipeline";
public static final String ENABLE_STRICT_CONSISTENCY_DML =
"enable_strict_consistency_dml";
public static final String ENABLE_BUSHY_TREE = "enable_bushy_tree";
@@ -751,6 +752,10 @@ public class SessionVariable implements Serializable,
Writable {
@VariableMgr.VarAttr(name = ENABLE_NEREIDS_DML, needForward = true)
public boolean enableNereidsDML = false;
+ @VariableMgr.VarAttr(name = ENABLE_NEREIDS_DML_WITH_PIPELINE, needForward
= true,
+ description = {"在新优化器中，使用pipeline引擎执行DML", "execute DML with
pipeline engine in Nereids"})
+ public boolean enableNereidsDmlWithPipeline = false;
+
@VariableMgr.VarAttr(name = ENABLE_STRICT_CONSISTENCY_DML, needForward =
true)
public boolean enableStrictConsistencyDml = false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
