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

[bug](sharedscan) Fix shared scan bug (#28841)

Browse Source
This commit is contained in:
Gabriel
2023-12-22 15:13:14 +08:00
committed by GitHub
parent 5420575184
commit cb61a0727f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2066,8 +2066,8 @@ public class Coordinator implements CoordInterface {
instanceParam.perNodeSharedScans.put(planNodeId, sharedScan);
params.instanceExecParams.add(instanceParam);
}
params.ignoreDataDistribution = sharedScan;
params.parallelTasksNum = sharedScan ? 1 : params.instanceExecParams.size();
params.ignoreDataDistribution = sharedScan && enablePipelineXEngine;
params.parallelTasksNum = params.ignoreDataDistribution ? 1 : params.instanceExecParams.size();
}
}
}
@ -2944,8 +2944,8 @@ public class Coordinator implements CoordInterface {
}
}
}
params.parallelTasksNum = ignoreStorageDataDistribution ? 1 : params.instanceExecParams.size();
params.ignoreDataDistribution = ignoreStorageDataDistribution;
params.ignoreDataDistribution = ignoreStorageDataDistribution && enablePipelineXEngine;
params.parallelTasksNum = params.ignoreDataDistribution ? 1 : params.instanceExecParams.size();
}
private final Map<PlanFragmentId, BucketSeqToScanRange> fragmentIdTobucketSeqToScanRangeMap = Maps.newHashMap();