From 9dc61f0918eecdf5143ed99c4019374b995de8de Mon Sep 17 00:00:00 2001
From: yanjiabao <yanjiabao@jd.com>
Date: Thu, 7 May 2020 10:52:38 +0800
Subject: [PATCH] fixed In the log service, when creating a log, add a raft
 group to all group peers, where the group peers are not all peers currently
 registered

---
 .../org/apache/ratis/logservice/server/MetaStateMachine.java    | 2 ++
 1 file changed, 2 insertions(+)

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<Message> processCreateLogRequest(
                 });
                 int provisionedPeers = 0;
                 Exception originalException = null;
+                // here 'peers', not List of the currently known all peers.
+                Collection<RaftPeer> peers = raftGroup.getPeers();
                 for (RaftPeer peer : peers) {
                     RaftClient client = RaftClient.newBuilder().setProperties(properties)
                         .setRaftGroup(RaftGroup.valueOf(logServerGroupId, peer)).build();