save

924060929 · Jun 12, 2024 · b05d490 · b05d490
1 parent 13383b4
commit b05d490
Showing 1 changed file with 4 additions and 4 deletions.
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
@@ -134,15 +134,15 @@ protected boolean useShareScan(Map<Worker, UninstancedScanSource> workerToScanRa
 
     protected boolean parallelTooLittle(Map<Worker, UninstancedScanSource> 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<Worker, UninstancedScanSource> 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<Worker, UninstancedScanSource> workerToScanRanges) {
+    protected boolean bucketsTooLittle(Map<Worker, UninstancedScanSource> workerToScanRanges) {
         int parallelExecNum = fragment.getParallelExecNum();
         for (UninstancedScanSource uninstancedScanSource : workerToScanRanges.values()) {
             ScanSource scanSource = uninstancedScanSource.scanSource;