diff --git a/pkg/common/discovery/kubernetes/kubernetes.go b/pkg/common/discovery/kubernetes/kubernetes.go
index 459f20e0b..dabddf94c 100644
--- a/pkg/common/discovery/kubernetes/kubernetes.go
+++ b/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()