From 7ac97c16500f47025f9ca4de95850b3f4da871b9 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Mon, 27 Nov 2023 21:29:02 +0800 Subject: [PATCH] [fix](bdbje) add free disk config (#27578) --- .../src/main/java/org/apache/doris/common/Config.java | 8 +++++++- .../org/apache/doris/journal/bdbje/BDBEnvironment.java | 2 ++ 2 files changed, 9 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 d1685b6247..7659cc8dee 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 @@ -236,10 +236,16 @@ public class Config extends ConfigBase { + "If there are many ReplicaWriteException in FE WARN log, you can try to increase this value"}) public static int bdbje_replica_ack_timeout_second = 10; + @ConfField(description = {"在HA模式下，BDBJE 中保留的预留空间字节数的期望上限。非 HA 模式下无效", + "The desired upper limit on the number of bytes of reserved space to retain " + + "in a replicated JE Environment. " + + "This parameter is ignored in a non-replicated JE Environment."}) + public static int bdbje_reserved_disk_bytes = 1 * 1024 * 1024 * 1024; // 1G + @ConfField(description = {"BDBJE 所需的空闲磁盘空间大小。如果空闲磁盘空间小于这个值，则BDBJE将无法写入。", "Amount of free disk space required by BDBJE. " + "If the free disk space is less than this value, BDBJE will not be able to write."}) - public static int bdbje_reserved_disk_bytes = 1 * 1024 * 1024 * 1024; // 1G + public static int bdbje_free_disk_bytes = 1 * 1024 * 1024 * 1024; // 1G @ConfField(masterOnly = true, description = {"心跳线程池的线程数", "Num of thread to handle heartbeat events"}) 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 47405c5c50..f2d1c1825c 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 @@ -138,6 +138,8 @@ public class BDBEnvironment { environmentConfig.setLockTimeout(Config.bdbje_lock_timeout_second, TimeUnit.SECONDS); environmentConfig.setConfigParam(EnvironmentConfig.RESERVED_DISK, String.valueOf(Config.bdbje_reserved_disk_bytes)); + environmentConfig.setConfigParam(EnvironmentConfig.FREE_DISK, + String.valueOf(Config.bdbje_free_disk_bytes)); if (BDBJE_LOG_LEVEL.contains(Config.bdbje_file_logging_level)) { java.util.logging.Logger parent = java.util.logging.Logger.getLogger("com.sleepycat.je");