From 3119ce2a6c7d7fcc1d3617fa08d15dee1ff410ab Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Wed, 30 Jun 2021 16:50:20 +0800
Subject: [PATCH] Stop create session in watch op (#6222)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datacoord/cluster.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()