From 72b1e2a346c75c891923f3f2d5e2797750713cdb Mon Sep 17 00:00:00 2001
From: Tiewei Fang <43782773+BePPPower@users.noreply.github.com>
Date: Sun, 10 Nov 2024 18:29:08 +0800
Subject: [PATCH] [fix](Outfile) forbid parallel outfile if pipeline engine
 enabled. (#43437)

Because pipeline engine doesn't implement parallel outfile, we should
forbid the parallel outfile if pipeline engine enabled.
---
 .../org/apache/doris/planner/OriginalPlanner.java | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/OriginalPlanner.java b/fe/fe-core/src/main/java/org/apache/doris/planner/OriginalPlanner.java
index a78209c2364533..24433af00e2d8a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/OriginalPlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/OriginalPlanner.java
@@ -358,16 +358,11 @@ private PlanNode addUnassignedConjuncts(Analyzer analyzer, PlanNode root)
      * The top plan fragment will only summarize the status of the exported result set and return it to fe.
      */
     private void pushDownResultFileSink(Analyzer analyzer) {
-        if (fragments.size() < 1) {
-            return;
-        }
-        if (!(fragments.get(0).getSink() instanceof ResultFileSink)) {
-            return;
-        }
-        if (!ConnectContext.get().getSessionVariable().isEnableParallelOutfile()) {
-            return;
-        }
-        if (!(fragments.get(0).getPlanRoot() instanceof ExchangeNode)) {
+        if (!ConnectContext.get().getSessionVariable().isEnableParallelOutfile()
+                || ConnectContext.get().getSessionVariable().getEnablePipelineEngine()
+                || fragments.size() < 1
+                || !(fragments.get(0).getPlanRoot() instanceof ExchangeNode)
+                || !(fragments.get(0).getSink() instanceof ResultFileSink)) {
             return;
         }
         PlanFragment topPlanFragment = fragments.get(0);