This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 f2fb23e98f [pipeline](exec) disable pipeline load in now version
(#21632)
f2fb23e98f is described below
commit f2fb23e98f00f1d4a3336a5894cb4ebb6b825587
Author: HappenLee <[email protected]>
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 287d39dc5b..ba1ec3e624 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, 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: [email protected]
For additional commands, e-mail: [email protected]
