This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/dev-1.1.2 by this push:
new e1df47e391 [fix](bdbje) add reserved disk config to avoid too many
reserved bdbje files (#12043)
e1df47e391 is described below
commit e1df47e391dd6314f2b6cdd0315735d38b97638c
Author: Mingyu Chen <[email protected]>
AuthorDate: Fri Aug 26 08:12:27 2022 +0800
[fix](bdbje) add reserved disk config to avoid too many reserved bdbje
files (#12043)
---
fe/fe-core/src/main/java/org/apache/doris/common/Config.java | 9 +++++++++
.../main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java | 2 ++
2 files changed, 11 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
index 6ac8b4353d..a52528f36c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
@@ -253,6 +253,15 @@ public class Config extends ConfigBase {
@ConfField
public static int bdbje_replica_ack_timeout_second = 10;
+ /**
+ * The desired upper limit on the number of bytes of reserved space to
+ * retain in a replicated JE Environment.
+ * You only need to decrease this value if your FE meta disk is really
small.
+ * And don't need to increase this value.
+ */
+ @ConfField
+ public static int bdbje_reserved_disk_bytes = 1 * 1024 * 1024 * 1024; // 1G
+
/**
* num of thread to handle heartbeat events in heartbeat_mgr.
*/
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
b/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
index 6e454b8fa9..f5f78ffa76 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
@@ -127,6 +127,8 @@ public class BDBEnvironment {
environmentConfig.setAllowCreate(true);
environmentConfig.setCachePercent(MEMORY_CACHE_PERCENT);
environmentConfig.setLockTimeout(Config.bdbje_lock_timeout_second,
TimeUnit.SECONDS);
+ environmentConfig.setConfigParam(EnvironmentConfig.RESERVED_DISK,
+ String.valueOf(Config.bdbje_reserved_disk_bytes));
if (isElectable) {
Durability durability = new
Durability(getSyncPolicy(Config.master_sync_policy),
getSyncPolicy(Config.replica_sync_policy),
getAckPolicy(Config.replica_ack_policy));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
