fix: missing peer id when refreshing leader, #1012

sofastack · Oct 20, 2023 · ad6eb5b · ad6eb5b
1 parent 5a855e0
commit ad6eb5b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java
@@ -232,11 +232,13 @@ public Status refreshLeader(final CliClientService cliClientService, final Strin
                 "Group %s is not registered in RouteTable, forgot to call updateConfiguration?", groupId);
         }
         final Status st = Status.OK();
-        final CliRequests.GetLeaderRequest.Builder rb = CliRequests.GetLeaderRequest.newBuilder();
-        rb.setGroupId(groupId);
-        final CliRequests.GetLeaderRequest request = rb.build();
+
         TimeoutException timeoutException = null;
         for (final PeerId peer : conf) {
+            final CliRequests.GetLeaderRequest.Builder rb = CliRequests.GetLeaderRequest.newBuilder();
+            rb.setGroupId(groupId);
+            rb.setPeerId(peer.toString());
+            final CliRequests.GetLeaderRequest request = rb.build();
             if (!cliClientService.connect(peer.getEndpoint())) {
                 if (st.isOk()) {
                     st.setError(-1, "Fail to init channel to %s", peer);