kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix isSelf address. (#3051)

This commit is contained in:
Alan Lau 2019-07-12 07:25:41 +08:00 committed by 吴晟 Wu Sheng
parent deb2d90029
commit 52b674e3a5
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oap-server/server-cluster-plugin/cluster-etcd-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/etcd/EtcdCoordinator.java
View File

@ -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));
});
}