Skip to content

Commit 163834a

Browse files
authored
[fix](bdbje) set maxMessageSize for bdbje (#50213)
default is cache size / 2. #50093 reduce memory consumed by fe via reducing cache size of bdbje.
1 parent 1f03d4b commit 163834a

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

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

+3
Original file line numberDiff line numberDiff line change
@@ -312,6 +312,9 @@ public class Config extends ConfigBase {
312312
@ConfField(description = {"BDBJE Cache 内存大小, 最小值为 96KB。", "Amount of memory used by by BDBJE as cache. "})
313313
public static long bdbje_cache_size_bytes = 10 * 1024 * 1024; // 10 MB
314314

315+
@ConfField(description = {"BDBJE Message 大小限制。", "Max message size of BDBJE. "})
316+
public static long bdbje_max_message_size_bytes = Integer.MAX_VALUE; // 2 GB
317+
315318
@ConfField(masterOnly = true, description = {"心跳线程池的线程数",
316319
"Num of thread to handle heartbeat events"})
317320
public static int heartbeat_mgr_threads_num = 8;

fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java

+2
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,8 @@ public void setup(File envHome, String selfNodeName, String selfNodeHostPort,
130130
replicationConfig.setNodeType(NodeType.SECONDARY);
131131
replicationConfig.setConsistencyPolicy(new NoConsistencyRequiredPolicy());
132132
}
133+
replicationConfig.setConfigParam(ReplicationConfig.MAX_MESSAGE_SIZE,
134+
String.valueOf(Config.bdbje_max_message_size_bytes));
133135

134136
// set environment config
135137
environmentConfig = new EnvironmentConfig();

0 commit comments

Comments
 (0)