database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](broker load) Make Config.enable_pipeline_load works as expected for BrokerLoad (#35105)

Browse Source 
* FIX LOAD PROFILE

* FIX
This commit is contained in:
zhiqiang
2024-05-21 19:22:58 +08:00
committed by yiguolei
parent b96148c9cd
commit e8fb47bec1
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -385,6 +385,10 @@ public class Coordinator implements CoordInterface {
nextInstanceId.setHi(queryId.hi);
nextInstanceId.setLo(queryId.lo + 1);
this.executionProfile = new ExecutionProfile(queryId, fragments);
// Need to be same with LoadLoadingTask
// https://github.com/apache/doris/blob/bd6f5b6a0e5f1b12744607336123d7f97eb76af9/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java#L155
this.enablePipelineEngine = Config.enable_pipeline_load;
this.enablePipelineXEngine = Config.enable_pipeline_load;
}
private void setFromUserProperty(ConnectContext connectContext) {