Skip to content

Commit

Permalink
fix checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Jun 27, 2024
1 parent 07dd821 commit 4026d2c
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,7 @@ private WorkerScanRanges selectScanReplicaAndMinWorkloadWorker(
minWorkload.recordOneScanTask(tabletBytes);
ScanRanges scanRanges = new ScanRanges();
TScanRangeParams scanReplicaParams =
buildScanReplicaParams(tabletLocation, selectedReplicaLocation);
ScanWorkerSelector.buildScanReplicaParams(tabletLocation, selectedReplicaLocation);
scanRanges.addScanRange(scanReplicaParams, tabletBytes);
return new WorkerScanRanges(minWorkLoadWorker, scanRanges);
}
Expand All @@ -241,7 +241,7 @@ private List<Pair<TScanRangeParams, Long>> filterReplicaByWorkerInBucket(
boolean foundTabletInThisWorker = false;
for (TScanRangeLocation replicaLocation : onePartitionOneTabletLocation.getLocations()) {
if (replicaLocation.getBackendId() == filterWorkerId) {
TScanRangeParams scanReplicaParams = buildScanReplicaParams(
TScanRangeParams scanReplicaParams = ScanWorkerSelector.buildScanReplicaParams(
onePartitionOneTabletLocation, replicaLocation);
Long replicaSize = ((OlapScanNode) scanNode).getTabletSingleReplicaSize(tabletId);
selectedReplicasInOneBucket.add(Pair.of(scanReplicaParams, replicaSize));
Expand All @@ -255,7 +255,7 @@ private List<Pair<TScanRangeParams, Long>> filterReplicaByWorkerInBucket(
}
} else if (onePartitionOneTabletLocation.getLocations().size() == 1) {
TScanRangeLocation replicaLocation = onePartitionOneTabletLocation.getLocations().get(0);
TScanRangeParams scanReplicaParams = buildScanReplicaParams(
TScanRangeParams scanReplicaParams = ScanWorkerSelector.buildScanReplicaParams(
onePartitionOneTabletLocation, replicaLocation);
Long replicaSize = 0L;
selectedReplicasInOneBucket.add(Pair.of(scanReplicaParams, replicaSize));
Expand Down

0 comments on commit 4026d2c

Please sign in to comment.