log

pkg/discoveryregistry/zookeeper/resolver.go

@@ -45,8 +45,9 @@ func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts re
 	r.ResolveNowZK(resolver.ResolveNowOptions{})
 	s.lock.Lock()
 	defer s.lock.Unlock()
-	s.resolvers[strings.TrimLeft(target.URL.Path, "/")] = r
-	s.logger.Printf("build resolver finished: %+v, cc: %+v, key: ", target, cc, strings.TrimLeft(target.URL.Path, "/"))
+	serviceName := strings.TrimLeft(target.URL.Path, "/")
+	s.resolvers[serviceName] = r
+	s.logger.Printf("build resolver finished: %+v, cc: %+v, key: ", target, cc, serviceName)
 	return r, nil
 }
 

pkg/discoveryregistry/zookeeper/zk.go

@@ -162,7 +162,6 @@ func (s *ZkClient) flushResolver(serviceName string) {
 	r, ok := s.resolvers[serviceName]
 	if ok {
 		r.ResolveNowZK(resolver.ResolveNowOptions{})
-		s.resolvers[serviceName] = r
 	}
 }