(doris) branch branch-2.0 updated: [opt](Nereids) add switch to control whether use pipeline in DML (#35728)

[morrysnow]

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 <101034200+morrys...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org