diff --git a/ratis-logservice/src/main/java/org/apache/ratis/logservice/server/MetaStateMachine.java b/ratis-logservice/src/main/java/org/apache/ratis/logservice/server/MetaStateMachine.java index ad1d7ee908..cbe6333b9c 100644 --- a/ratis-logservice/src/main/java/org/apache/ratis/logservice/server/MetaStateMachine.java +++ b/ratis-logservice/src/main/java/org/apache/ratis/logservice/server/MetaStateMachine.java @@ -318,6 +318,8 @@ private CompletableFuture processCreateLogRequest( }); int provisionedPeers = 0; Exception originalException = null; + // here 'peers', not List of the currently known all peers. + Collection peers = raftGroup.getPeers(); for (RaftPeer peer : peers) { RaftClient client = RaftClient.newBuilder().setProperties(properties) .setRaftGroup(RaftGroup.valueOf(logServerGroupId, peer)).build();