Merge 5b265c5a3f into 175a7bb067

pkg/common/discovery/kubernetes/kubernetes.go

@@ -101,6 +101,7 @@ func (k *KubernetesConnManager) GetConns(ctx context.Context, serviceName string
 	// Check if another goroutine has already initialized the connections when we released the read lock
 	conns, exists = k.connMap[serviceName]
 	if exists {
+		k.mu.Unlock()
 		return conns, nil
 	}
 	k.mu.Unlock()