This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new cf849987114 Revert "[fix](broker load) Make
Config.enable_pipeline_load works as expected for BrokerLoad (#35105)"
cf849987114 is described below
commit cf8499871143b6cf6d197bfcea2ace9d1a193ab8
Author: yiguolei <[email protected]>
AuthorDate: Fri May 24 19:28:34 2024 +0800
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 3baaace0aaf..e0fe0eead00 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
