From 814acbf331cdc38fd542d174df1d2e915a33085c Mon Sep 17 00:00:00 2001
From: HappenLee <happenlee@hotmail.com>
Date: Wed, 16 Aug 2023 21:53:58 +0800
Subject: [PATCH] [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);