diff --git a/internal/querynodev2/cluster/worker.go b/internal/querynodev2/cluster/worker.go
index af524cb899..9548b05b3a 100644
--- a/internal/querynodev2/cluster/worker.go
+++ b/internal/querynodev2/cluster/worker.go
@@ -209,6 +209,7 @@ func (w *remoteWorker) Stop() {
 		for _, client := range w.clients {
 			client.Close()
 		}
+		return
 	}
 	if err := w.client.Close(); err != nil {
 		log.Warn("failed to call Close via grpc worker", zap.Error(err))