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

[fix](tablet sched) disable disk balance for single replica (#29576)

Browse Source
This commit is contained in:
yujun
2024-01-07 19:21:42 +08:00
committed by GitHub
parent eb2b22bff1
commit 2d89b7aed4
2 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/clone/DiskRebalancer.java
View File

@ -27,6 +27,7 @@ import org.apache.doris.clone.SchedException.SubCode;
import org.apache.doris.clone.TabletSchedCtx.BalanceType;
import org.apache.doris.clone.TabletSchedCtx.Priority;
import org.apache.doris.clone.TabletScheduler.PathSlot;
import org.apache.doris.common.Config;
import org.apache.doris.common.FeConstants;
import org.apache.doris.system.SystemInfoService;
import org.apache.doris.thrift.TStorageMedium;
@ -210,6 +211,10 @@ public class DiskRebalancer extends Rebalancer {
if (alternativeTabletIds.contains(tabletId)) {
continue;
}
if (!Config.enable_disk_balance_for_single_replica
&& invertedIndex.getReplicasByTabletId(tabletId).size() <= 1) {
continue;
}
Replica replica = invertedIndex.getReplica(tabletId, beStat.getBeId());
if (replica == null) {
continue;