This is an automated email from the ASF dual-hosted git repository.
jianbin pushed a commit to branch 2.x
in repository https://gitbox.apache.org/repos/asf/incubator-seata.git
The following commit(s) were added to refs/heads/2.x by this push:
new 35945899a2 optimize: Remove unnecessary refreshLeader from
ClusterController cluster endpoint (#7970)
35945899a2 is described below
commit 35945899a2134dd05f9488c34386be65aca26f3b
Author: Sumit Kesarwani <[email protected]>
AuthorDate: Tue Feb 3 06:55:33 2026 +0530
optimize: Remove unnecessary refreshLeader from ClusterController cluster
endpoint (#7970)
---
.../apache/seata/server/controller/ClusterController.java | 15 ++++-----------
1 file changed, 4 insertions(+), 11 deletions(-)
diff --git
a/server/src/main/java/org/apache/seata/server/controller/ClusterController.java
b/server/src/main/java/org/apache/seata/server/controller/ClusterController.java
index 19f2623ec4..9104d49ca4 100644
---
a/server/src/main/java/org/apache/seata/server/controller/ClusterController.java
+++
b/server/src/main/java/org/apache/seata/server/controller/ClusterController.java
@@ -18,7 +18,6 @@ package org.apache.seata.server.controller;
import com.alipay.sofa.jraft.RouteTable;
import com.alipay.sofa.jraft.conf.Configuration;
-import com.alipay.sofa.jraft.entity.PeerId;
import org.apache.seata.common.ConfigurationKeys;
import org.apache.seata.common.metadata.MetadataResponse;
import org.apache.seata.common.metadata.Node;
@@ -85,18 +84,12 @@ public class ClusterController {
if (raftServer != null) {
String mode =
ConfigurationFactory.getInstance().getConfig(STORE_MODE);
metadataResponse.setStoreMode(mode);
- RouteTable routeTable = RouteTable.getInstance();
try {
-
routeTable.refreshLeader(RaftServerManager.getCliClientServiceInstance(),
group, 1000);
- PeerId leader = routeTable.selectLeader(group);
- if (leader != null) {
+ RaftClusterMetadata raftClusterMetadata =
+
raftServer.getRaftStateMachine().getRaftLeaderMetadata();
+ Node leaderNode = raftClusterMetadata.getLeader();
+ if (leaderNode != null) {
Set<Node> nodes = new HashSet<>();
- RaftClusterMetadata raftClusterMetadata =
-
raftServer.getRaftStateMachine().getRaftLeaderMetadata();
- Node leaderNode = raftServer
- .getRaftStateMachine()
- .getRaftLeaderMetadata()
- .getLeader();
leaderNode.setGroup(group);
nodes.add(leaderNode);
nodes.addAll(raftClusterMetadata.getLearner());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
