From b05137872d8b51a7e10afd9874023200ec4b496b Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 30 Jun 2023 12:31:13 +0800 Subject: [PATCH] log --- pkg/discoveryregistry/zookeeper/resolver.go | 5 +++-- pkg/discoveryregistry/zookeeper/zk.go | 1 - 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/discoveryregistry/zookeeper/resolver.go b/pkg/discoveryregistry/zookeeper/resolver.go index 2b6653841..3dce4a12c 100644 --- a/pkg/discoveryregistry/zookeeper/resolver.go +++ b/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 } diff --git a/pkg/discoveryregistry/zookeeper/zk.go b/pkg/discoveryregistry/zookeeper/zk.go index 2b47c9f77..be0fb5bb0 100644 --- a/pkg/discoveryregistry/zookeeper/zk.go +++ b/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 } }