From d45e7fec67cd7d29eaaee522a1f7098a3fd48f83 Mon Sep 17 00:00:00 2001
From: pengys5 <8082209@qq.com>
Date: Sun, 10 Sep 2017 21:11:54 +0800
Subject: [PATCH] no message

---
 .../apm/collector/stream/grpc/StreamGRPCDataListener.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apm-collector/apm-collector-stream/src/main/java/org/skywalking/apm/collector/stream/grpc/StreamGRPCDataListener.java b/apm-collector/apm-collector-stream/src/main/java/org/skywalking/apm/collector/stream/grpc/StreamGRPCDataListener.java
index 445a17e45..92c86d47c 100644
--- a/apm-collector/apm-collector-stream/src/main/java/org/skywalking/apm/collector/stream/grpc/StreamGRPCDataListener.java
+++ b/apm-collector/apm-collector-stream/src/main/java/org/skywalking/apm/collector/stream/grpc/StreamGRPCDataListener.java
@@ -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);
                 });
-- 
GitLab