[doris] 29/29: [pipeline](exec) disable pipeline load in now version (#21632)

[kxiao]

This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 2fa898e9d9a0d0450f8c7fff912542c9e4b5c9af
Author: HappenLee <happen...@hotmail.com>
AuthorDate: Sun Jul 9 01:00:06 2023 +0800

    [pipeline](exec) disable pipeline load in now version (#21632)
---
 fe/fe-common/src/main/java/org/apache/doris/common/Config.java | 2 +-
 fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java  | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java 
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index 51cf3d0f99..35bc4585d6 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -1495,7 +1495,7 @@ public class Config extends ConfigBase {
     public static boolean enable_quantile_state_type = true;
 
     @ConfField
-    public static boolean enable_pipeline_load = true;
+    public static boolean enable_pipeline_load = false;
 
     // enable_workload_group should be immutable and temporarily set to 
mutable during the development test phase
     @ConfField(mutable = true, masterOnly = true, expType = 
ExperimentalType.EXPERIMENTAL)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index a18248a017..180e3e1c75 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -310,7 +310,9 @@ public class Coordinator {
 
         this.returnedAllResults = false;
         this.enableShareHashTableForBroadcastJoin = 
context.getSessionVariable().enableShareHashTableForBroadcastJoin;
-        this.enablePipelineEngine = 
context.getSessionVariable().getEnablePipelineEngine();
+        // Only enable pipeline query engine in query, not load
+        this.enablePipelineEngine = 
context.getSessionVariable().getEnablePipelineEngine()
+                && (fragments.size() > 0 && fragments.get(0).getSink() 
instanceof ResultSink);
         initQueryOptions(context);
 
         setFromUserProperty(context);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org