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 9e6cfe5c0f bug: setting up a Raft cluster using domain, the listening
request port is error (#6551)
9e6cfe5c0f is described below
commit 9e6cfe5c0fc6bf134d48dfe6a2879cc7669d8abf
Author: zacharias1989 <[email protected]>
AuthorDate: Wed Jun 26 17:58:40 2024 +0800
bug: setting up a Raft cluster using domain, the listening request port is
error (#6551)
---
.../apache/seata/discovery/registry/raft/RaftRegistryServiceImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/discovery/seata-discovery-raft/src/main/java/org/apache/seata/discovery/registry/raft/RaftRegistryServiceImpl.java
b/discovery/seata-discovery-raft/src/main/java/org/apache/seata/discovery/registry/raft/RaftRegistryServiceImpl.java
index 11dc1409dd..ad0555e457 100644
---
a/discovery/seata-discovery-raft/src/main/java/org/apache/seata/discovery/registry/raft/RaftRegistryServiceImpl.java
+++
b/discovery/seata-discovery-raft/src/main/java/org/apache/seata/discovery/registry/raft/RaftRegistryServiceImpl.java
@@ -234,8 +234,8 @@ public class RaftRegistryServiceImpl implements
RegistryService<ConfigChangeList
Map<String, Node> map = new HashMap<>();
if (CollectionUtils.isNotEmpty(nodeList)) {
for (Node node : nodeList) {
- map.put(node.getTransaction().getHost() +
IP_PORT_SPLIT_CHAR + node.getTransaction().getPort(),
- node);
+ map.put(new
InetSocketAddress(node.getTransaction().getHost(),
node.getTransaction().getPort()).getAddress().getHostAddress()
+ + IP_PORT_SPLIT_CHAR +
node.getTransaction().getPort(), node);
}
}
addressList = stream.map(inetSocketAddress -> {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
