This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new cb27af7623d [fix](disk balance) Change disk rebalance unpick time to
configurable (#28949) (#30059)
cb27af7623d is described below
commit cb27af7623d5ce2c5db7417beb26b3ea0fced698
Author: deardeng <[email protected]>
AuthorDate: Fri Jan 19 10:36:09 2024 +0800
[fix](disk balance) Change disk rebalance unpick time to configurable
(#28949) (#30059)
---
fe/fe-common/src/main/java/org/apache/doris/common/Config.java | 6 ++++++
fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java | 3 ++-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index adffe19d3cb..36dcfc1f8d0 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -1017,6 +1017,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 = 0;
+
/**
* if set to true, TabletScheduler will not do disk balance.
*/
diff --git a/fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java
b/fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java
index 8f6b1d229f0..def9e18a7e3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/clone/Rebalancer.java
@@ -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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
