This is an automated email from the ASF dual-hosted git repository.
panxiaolei 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 814acbf331 [pipeline](exec) disable pipeline load in master code
(#23061)
814acbf331 is described below
commit 814acbf331cdc38fd542d174df1d2e915a33085c
Author: HappenLee <[email protected]>
AuthorDate: Wed Aug 16 21:53:58 2023 +0800
[pipeline](exec) disable pipeline load in master code (#23061)
disable pipeline load in master code
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 32829d2db5..6edc8d6744 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
@@ -322,7 +322,7 @@ public class Coordinator {
this.enableShareHashTableForBroadcastJoin =
context.getSessionVariable().enableShareHashTableForBroadcastJoin;
// Only enable pipeline query engine in query, not load
this.enablePipelineEngine =
context.getSessionVariable().getEnablePipelineEngine()
- && fragments.size() > 0;
+ && (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]
