[pipeline](exec) disable pipeline load in now version (#21632)

This commit is contained in:
HappenLee
2023-07-09 01:00:06 +08:00
committed by GitHub
parent 1b226ff8a2
commit f2fb23e98f
2 changed files with 4 additions and 2 deletions

View File

@ -310,7 +310,9 @@ public class Coordinator {
this.returnedAllResults = false;
this.enableShareHashTableForBroadcastJoin = context.getSessionVariable().enableShareHashTableForBroadcastJoin;
this.enablePipelineEngine = context.getSessionVariable().getEnablePipelineEngine();
// Only enable pipeline query engine in query, not load
this.enablePipelineEngine = context.getSessionVariable().getEnablePipelineEngine()
&& (fragments.size() > 0 && fragments.get(0).getSink() instanceof ResultSink);
initQueryOptions(context);
setFromUserProperty(context);