[fix](pipelineX) add table sink and some fix in pipelineX (#25314)

2023-10-11 20:18:08 +08:00
parent e94fca4949
commit ba87f7d3a3
11 changed files with 178 additions and 19 deletions
--- 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
@ -323,7 +323,7 @@ public class Coordinator implements CoordInterface {
        this.enablePipelineEngine = context.getSessionVariable().getEnablePipelineEngine()
                && (fragments.size() > 0);
        this.enablePipelineXEngine = context.getSessionVariable().getEnablePipelineXEngine()
-                && (fragments.size() > 0 && fragments.get(0).getSink() instanceof ResultSink);
+                && (fragments.size() > 0);

        initQueryOptions(context);