milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Stop create session in watch op (#6222) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/6227/head^2
congqixia 2021-06-30 16:50:20 +08:00 committed by GitHub
parent 49a0528d53
commit 3119ce2a6c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datacoord/cluster.go
View File

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