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

[feat](pipelinex) support parallel scan on pipeline x engine (#29070)

Browse Source 
* [feat](pipelinex) support parallel scan on pipeline x engine

* make parallel scan be independent of shared scan
This commit is contained in:
Jerry Hu
2023-12-28 21:29:07 +08:00
committed by GitHub
parent 0912b137e6
commit ffd178f5ff
4 changed files with 94 additions and 22 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

@ -1099,6 +1099,10 @@ public class Coordinator implements CoordInterface {
try {
PExecPlanFragmentResult result = triple.getRight().get(timeoutMs, TimeUnit.MILLISECONDS);
code = TStatusCode.findByValue(result.getStatus().getStatusCode());
if (code == null) {
code = TStatusCode.INTERNAL_ERROR;
}
if (code != TStatusCode.OK) {
if (!result.getStatus().getErrorMsgsList().isEmpty()) {
errMsg = result.getStatus().getErrorMsgsList().get(0);