(iotdb) branch master updated: fix remaining issues when upgrading to ratis 3.0.1 (#11921)

[tanxinyu]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new a965709cd3a fix remaining issues when upgrading to ratis 3.0.1 (#11921)
a965709cd3a is described below

commit a965709cd3aa284d8eb6f437e3d217a94f6a5e5f
Author: William Song <48054931+szywill...@users.noreply.github.com>
AuthorDate: Thu Jan 18 11:10:10 2024 +0800

    fix remaining issues when upgrading to ratis 3.0.1 (#11921)
---
 .../org/apache/iotdb/consensus/config/RatisConfig.java     | 14 --------------
 .../org/apache/iotdb/consensus/ratis/RecoverReadTest.java  |  2 +-
 2 files changed, 1 insertion(+), 15 deletions(-)

diff --git 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
index 50d4efd93f9..0e9cffea6d3 100644
--- 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
+++ 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
@@ -550,7 +550,6 @@ public class RatisConfig {
     private final int segmentCacheNumMax;
     private final SizeInBytes segmentCacheSizeMax;
     private final SizeInBytes preallocatedSize;
-    private final SizeInBytes writeBufferSize;
     private final int forceSyncNum;
     private final boolean unsafeFlushEnabled;
 
@@ -565,7 +564,6 @@ public class RatisConfig {
         int segmentCacheNumMax,
         SizeInBytes segmentCacheSizeMax,
         SizeInBytes preallocatedSize,
-        SizeInBytes writeBufferSize,
         int forceSyncNum,
         boolean unsafeFlushEnabled) {
       this.useMemory = useMemory;
@@ -578,7 +576,6 @@ public class RatisConfig {
       this.segmentCacheNumMax = segmentCacheNumMax;
       this.segmentCacheSizeMax = segmentCacheSizeMax;
       this.preallocatedSize = preallocatedSize;
-      this.writeBufferSize = writeBufferSize;
       this.forceSyncNum = forceSyncNum;
       this.unsafeFlushEnabled = unsafeFlushEnabled;
     }
@@ -619,10 +616,6 @@ public class RatisConfig {
       return preallocatedSize;
     }
 
-    public SizeInBytes getWriteBufferSize() {
-      return writeBufferSize;
-    }
-
     public int getForceSyncNum() {
       return forceSyncNum;
     }
@@ -651,7 +644,6 @@ public class RatisConfig {
       private int segmentCacheNumMax = 2;
       private SizeInBytes segmentCacheSizeMax = SizeInBytes.valueOf("200MB");
       private SizeInBytes preallocatedSize = SizeInBytes.valueOf("4MB");
-      private SizeInBytes writeBufferSize = SizeInBytes.valueOf("8MB");
       private int forceSyncNum = 128;
       private boolean unsafeFlushEnabled = true;
 
@@ -667,7 +659,6 @@ public class RatisConfig {
             segmentCacheNumMax,
             segmentCacheSizeMax,
             preallocatedSize,
-            writeBufferSize,
             forceSyncNum,
             unsafeFlushEnabled);
       }
@@ -722,11 +713,6 @@ public class RatisConfig {
         return this;
       }
 
-      public Log.Builder setWriteBufferSize(SizeInBytes writeBufferSize) {
-        this.writeBufferSize = writeBufferSize;
-        return this;
-      }
-
       public Log.Builder setForceSyncNum(int forceSyncNum) {
         this.forceSyncNum = forceSyncNum;
         return this;
diff --git 
a/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RecoverReadTest.java
 
b/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RecoverReadTest.java
index f7a03339c91..ac8115ced85 100644
--- 
a/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RecoverReadTest.java
+++ 
b/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RecoverReadTest.java
@@ -208,7 +208,7 @@ public class RecoverReadTest {
   }
 
   @Test
-  public void consistentReadTimeout() throws Exception {
+  public void consistentReadWithSlowApply() throws Exception {
     final ConsensusGroupId gid = miniCluster.getGid();
     final List<Peer> members = miniCluster.getPeers();