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 3234af90ff9d29..6d07a00690729c 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 @@ -134,15 +134,15 @@ protected boolean useShareScan(Map workerToScanRa protected boolean parallelTooLittle(Map workerToScanRanges) { if (this instanceof UnassignedScanBucketOlapTableJob) { - return scanRangeToLittle(workerToScanRanges) && bucketTooLittle(workerToScanRanges); + return scanRangesToLittle(workerToScanRanges) && bucketsTooLittle(workerToScanRanges); } else if (!scanNodes.isEmpty()) { - return scanRangeToLittle(workerToScanRanges); + return scanRangesToLittle(workerToScanRanges); } else { return false; } } - protected boolean scanRangeToLittle( + protected boolean scanRangesToLittle( Map workerToScanRanges) { ConnectContext context = ConnectContext.get(); int backendNum = workerToScanRanges.size(); @@ -173,7 +173,7 @@ protected int degreeOfParallelism(int maxParallel) { return Math.min(maxParallel, Math.max(fragment.getParallelExecNum(), 1)); } - protected boolean bucketTooLittle(Map workerToScanRanges) { + protected boolean bucketsTooLittle(Map workerToScanRanges) { int parallelExecNum = fragment.getParallelExecNum(); for (UninstancedScanSource uninstancedScanSource : workerToScanRanges.values()) { ScanSource scanSource = uninstancedScanSource.scanSource;