Fix ratis byte limit configuration too small (#14449)

Signed-off-by: OneSizeFitQuorum <[email protected]>
apache · Dec 17, 2024 · 5f7b570 · 5f7b570
1 parent d3f6392
commit 5f7b570
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java
@@ -310,7 +310,8 @@ public static void initRatisConfig(RaftProperties properties, RatisConfig config
         properties, RaftServerConfigKeys.Log.CorruptionPolicy.WARN_AND_RETURN);
 
     RaftServerConfigKeys.Write.setByteLimit(
-        properties, config.getLeaderLogAppender().getBufferByteLimit());
+        properties,
+        SizeInBytes.valueOf(config.getLeaderLogAppender().getBufferByteLimit().getSize() * 10));
 
     RaftServerConfigKeys.Log.setQueueByteLimit(
         properties, config.getLeaderLogAppender().getBufferByteLimit());