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

[fix](disk balance) Change disk rebalance unpick time to configurable (#28949)

Browse Source
This commit is contained in:
deardeng
2024-01-16 17:31:44 +08:00
committed by yiguolei
parent 74991c4af2
commit 168afdb965
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-common/src/main/java/org/apache/doris/common/Config.java
View File

@ -1020,6 +1020,12 @@ public class Config extends ConfigBase {
@ConfField(mutable = true, masterOnly = true)
public static boolean disable_balance = false;
/**
* when be rebalancer idle, then disk balance will occurs.
*/
@ConfField(mutable = true, masterOnly = true)
public static int be_rebalancer_idle_seconds = 60;
/**
* if set to true, TabletScheduler will not do disk balance.
*/

3
fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java
View File

@ -19,6 +19,7 @@ package org.apache.doris.clone;
import org.apache.doris.catalog.TabletInvertedIndex;
import org.apache.doris.clone.TabletScheduler.PathSlot;
import org.apache.doris.common.Config;
import org.apache.doris.resource.Tag;
import org.apache.doris.system.Backend;
import org.apache.doris.system.SystemInfoService;
@ -100,7 +101,7 @@ public abstract class Rebalancer {
Long lastPickTime = lastPickTimeTable.get(tag, medium);
Long now = System.currentTimeMillis();
LOG.debug("tag={}, medium={}, lastPickTime={}, now={}", tag, medium, lastPickTime, now);
return lastPickTime == null || now - lastPickTime >= 5 * 60 * 1000L;
return lastPickTime == null || now - lastPickTime >= Config.be_rebalancer_idle_seconds * 1000L;
}
public AgentTask createBalanceTask(TabletSchedCtx tabletCtx)