diff --git a/pkg/discoveryregistry/zookeeper/discover.go b/pkg/discoveryregistry/zookeeper/discover.go index 2142bde21..d51b0531d 100644 --- a/pkg/discoveryregistry/zookeeper/discover.go +++ b/pkg/discoveryregistry/zookeeper/discover.go @@ -83,6 +83,7 @@ func (s *ZkClient) GetConns(ctx context.Context, serviceName string, opts ...grp log.ZDebug(ctx, "get conns from zk remote", "serviceName", serviceName) conns, err = s.GetConnsRemote(serviceName) if err != nil { + s.lock.Unlock() return nil, err } s.localConns[serviceName] = conns