From 1cbabf76e2e597c8ea458ba0cc1d20f7fb1c65f6 Mon Sep 17 00:00:00 2001 From: 924060929 <924060929@qq.com> Date: Wed, 12 Jun 2024 20:30:18 +0800 Subject: [PATCH] save --- .../doris/nereids/worker/job/AbstractUnassignedScanJob.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java index a701657e51cf6c..bb547ae0f650d4 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java @@ -135,7 +135,8 @@ protected boolean useShareScan(Map workerToScanRa protected boolean parallelTooLittle(Map workerToScanRanges) { if (this instanceof UnassignedScanBucketOlapTableJob) { return scanRangesToLittle(workerToScanRanges) && bucketsTooLittle(workerToScanRanges); - } else if (!scanNodes.isEmpty()) { + } else if (this instanceof UnassignedScanSingleOlapTableJob + || this instanceof UnassignedScanSingleRemoteTableJob) { return scanRangesToLittle(workerToScanRanges); } else { return false;