Skip to content

Commit e9dae54

Browse files
committed
fix
1 parent d1867fe commit e9dae54

File tree

1 file changed

+5
-10
lines changed

1 file changed

+5
-10
lines changed

fe/fe-core/src/main/java/org/apache/doris/planner/OriginalPlanner.java

+5-10
Original file line numberDiff line numberDiff line change
@@ -349,16 +349,11 @@ private PlanNode addUnassignedConjuncts(Analyzer analyzer, PlanNode root)
349349
* The top plan fragment will only summarize the status of the exported result set and return it to fe.
350350
*/
351351
private void pushDownResultFileSink(Analyzer analyzer) {
352-
if (fragments.size() < 1) {
353-
return;
354-
}
355-
if (!(fragments.get(0).getSink() instanceof ResultFileSink)) {
356-
return;
357-
}
358-
if (!ConnectContext.get().getSessionVariable().isEnableParallelOutfile()) {
359-
return;
360-
}
361-
if (!(fragments.get(0).getPlanRoot() instanceof ExchangeNode)) {
352+
if (!ConnectContext.get().getSessionVariable().isEnableParallelOutfile()
353+
|| ConnectContext.get().getSessionVariable().getEnablePipelineEngine()
354+
|| fragments.size() < 1
355+
|| !(fragments.get(0).getPlanRoot() instanceof ExchangeNode)
356+
|| !(fragments.get(0).getSink() instanceof ResultFileSink)) {
362357
return;
363358
}
364359
PlanFragment topPlanFragment = fragments.get(0);

0 commit comments

Comments
 (0)