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

no message

This commit is contained in:
pengys5 2017-09-10 21:11:54 +08:00
parent 897cd24252
commit d45e7fec67
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apm-collector/apm-collector-stream/src/main/java/org/skywalking/apm/collector/stream/grpc/StreamGRPCDataListener.java
View File

@ -56,7 +56,7 @@ public class StreamGRPCDataListener extends ClusterDataListener {
logger.info("create remote worker reference, role: {}", provider.role().roleName());
RemoteWorkerRef remoteWorkerRef = provider.create(client);
if (!remoteWorkerRefMap.containsKey(serverAddress)) {
remoteWorkerRefMap.put(selfAddress, new LinkedList<>());
remoteWorkerRefMap.put(serverAddress, new LinkedList<>());
}
remoteWorkerRefMap.get(serverAddress).add(remoteWorkerRef);
});