From 1fda882464ef3cde037b6fdf55a1775a6df55adf Mon Sep 17 00:00:00 2001 From: HappenLee Date: Fri, 7 Jul 2023 18:14:13 +0800 Subject: [PATCH] [pipeline](exec) disable pipeline load in now version --- .../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 287d39dc5b9c261..ba1ec3e62407e44 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 a18248a017e071b..589a116ff3b9713 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 Coordinator(ConnectContext context, Analyzer analyzer, Planner planner) { 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().enablePipelineEngine + && (fragments.get(0).getSink() instanceof ResultSink); initQueryOptions(context); setFromUserProperty(context);