From 52b674e3a55c2f6197e2b3adef15ff947576cd2a Mon Sep 17 00:00:00 2001 From: Alan Lau Date: Fri, 12 Jul 2019 07:25:41 +0800 Subject: [PATCH] Fix isSelf address. (#3051) --- .../oap/server/cluster/plugin/etcd/EtcdCoordinator.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/oap-server/server-cluster-plugin/cluster-etcd-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/etcd/EtcdCoordinator.java b/oap-server/server-cluster-plugin/cluster-etcd-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/etcd/EtcdCoordinator.java index 8a7df694c8..b61415845a 100644 --- a/oap-server/server-cluster-plugin/cluster-etcd-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/etcd/EtcdCoordinator.java +++ b/oap-server/server-cluster-plugin/cluster-etcd-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/etcd/EtcdCoordinator.java @@ -68,7 +68,11 @@ public class EtcdCoordinator implements ClusterRegister, ClusterNodesQuery { if (nodes != null) { nodes.forEach(node -> { EtcdEndpoint endpoint = gson.fromJson(node.getValue(), EtcdEndpoint.class); - res.add(new RemoteInstance(new Address(endpoint.getHost(), endpoint.getPort(), true))); + Address address = new Address(endpoint.getHost(), endpoint.getPort(), true); + if (!address.equals(selfAddress)) { + address.setSelf(false); + } + res.add(new RemoteInstance(address)); }); } -- GitLab