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 index 367b330ac3ec..bb32631a1b4e 100644 --- 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());