From cf8499871143b6cf6d197bfcea2ace9d1a193ab8 Mon Sep 17 00:00:00 2001 From: yiguolei Date: Fri, 24 May 2024 19:28:34 +0800 Subject: [PATCH] Revert "[fix](broker load) Make Config.enable_pipeline_load works as expected for BrokerLoad (#35105)" This reverts commit e8fb47bec1a1cfc7b07a6ed4eb36283407a4a9fe. --- fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ---- 1 file changed, 4 deletions(-) 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 3baaace0aa..e0fe0eead0 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 @@ -385,10 +385,6 @@ public class Coordinator implements CoordInterface { nextInstanceId.setHi(queryId.hi); nextInstanceId.setLo(queryId.lo + 1); this.executionProfile = new ExecutionProfile(queryId, fragments); - // Need to be same with LoadLoadingTask - // https://github.com/apache/doris/blob/bd6f5b6a0e5f1b12744607336123d7f97eb76af9/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java#L155 - this.enablePipelineEngine = Config.enable_pipeline_load; - this.enablePipelineXEngine = Config.enable_pipeline_load; } private void setFromUserProperty(ConnectContext connectContext) {