This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new ffb5950d9e8 [exec](pipeline) enable pipeline dml in coordinator
(#39365)
ffb5950d9e8 is described below
commit ffb5950d9e8273dd38a22830e77b1a8b76576489
Author: HappenLee <happen...@hotmail.com>
AuthorDate: Mon Aug 26 22:12:41 2024 +0800
[exec](pipeline) enable pipeline dml in coordinator (#39365)
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 3 +--
1 file changed, 1 insertion(+), 2 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 869db1e7d89..85f4201eb1e 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
@@ -300,8 +300,7 @@ public class Coordinator implements CoordInterface {
this.returnedAllResults = false;
this.enableShareHashTableForBroadcastJoin =
context.getSessionVariable().enableShareHashTableForBroadcastJoin;
// Only enable pipeline query engine in query, not load
- this.enablePipelineEngine =
context.getSessionVariable().getEnablePipelineEngine()
- && (fragments.size() > 0 && fragments.get(0).getSink()
instanceof ResultSink);
+ this.enablePipelineEngine =
context.getSessionVariable().getEnablePipelineEngine();
this.fasterFloatConvert =
context.getSessionVariable().fasterFloatConvert();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
