Skip to content

Commit 1d96630

Browse files
CRZbulabulaJackieTien97
authored andcommitted
Remove Ratis region migration rate limiting (#18365)
1 parent 1b9cc22 commit 1d96630

5 files changed

Lines changed: 0 additions & 221 deletions

File tree

‎iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java‎

Lines changed: 0 additions & 40 deletions
This file was deleted.

‎iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java‎

Lines changed: 0 additions & 76 deletions
This file was deleted.

‎iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java‎

Lines changed: 0 additions & 37 deletions
This file was deleted.

‎iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@
5656
import org.apache.iotdb.rpc.TSStatusCode;
5757

5858
import org.apache.commons.pool2.impl.GenericKeyedObjectPool;
59-
import org.apache.ratis.RaftConfigKeys;
6059
import org.apache.ratis.client.RaftClientRpc;
6160
import org.apache.ratis.conf.Parameters;
6261
import org.apache.ratis.conf.RaftProperties;
@@ -160,7 +159,6 @@ public RatisConsensus(ConsensusConfig config, IStateMachine.Registry registry) {
160159
this.storageDir = new File(config.getStorageDir());
161160

162161
RaftServerConfigKeys.setStorageDir(properties, Collections.singletonList(storageDir));
163-
RaftConfigKeys.Rpc.setType(properties, new RateLimitedGrpcRpcType());
164162
GrpcConfigKeys.Server.setHost(properties, config.getThisNodeEndPoint().getIp());
165163
GrpcConfigKeys.Server.setPort(properties, config.getThisNodeEndPoint().getPort());
166164

‎iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppenderTest.java‎

Lines changed: 0 additions & 66 deletions
This file was deleted.

0 commit comments

Comments
 (0)