diff --git a/internal/datacoord/cluster.go b/internal/datacoord/cluster.go
index 2191ad69e5..224affa2fd 100644
--- a/internal/datacoord/cluster.go
+++ b/internal/datacoord/cluster.go
@@ -264,7 +264,7 @@ func (c *cluster) watch(nodes []*datapb.DataNodeInfo) ([]*datapb.DataNodeInfo, e
 				mut.Unlock()
 				return
 			}
-			cli, err := c.sessionManager.getOrCreateSession(n.Address) // this might take time if address went offline
+			cli, err := c.sessionManager.getSession(n.Address) //fail fast, don't create session
 			if err != nil {
 				log.Warn("get session failed", zap.String("addr", n.Address), zap.Error(err))
 				mut.Lock()