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

Adding indexnode should be processed asynchronously (#7141) 

Signed-off-by: cai.zhang <cai.zhang@zilliz.com>
pull/7143/head
cai.zhang 2021-08-17 20:26:11 +08:00 committed by GitHub
parent c2a4bd3e9c
commit 3d83e99a99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/indexcoord/index_coord.go
View File

@ -129,10 +129,14 @@ func (i *IndexCoord) Init() error {
log.Debug("IndexCoord", zap.Any("Get IndexNode Sessions error", err))
}
for _, session := range sessions {
if err = i.nodeManager.AddNode(session.ServerID, session.Address); err != nil {
log.Debug("IndexCoord", zap.Any("ServerID", session.ServerID),
zap.Any("Add IndexNode error", err))
}
session := session
go func() {
if err = i.nodeManager.AddNode(session.ServerID, session.Address); err != nil {
log.Debug("IndexCoord", zap.Any("ServerID", session.ServerID),
zap.Any("Add IndexNode error", err))
}
}()
}
log.Debug("IndexCoord", zap.Any("IndexNode number", len(i.nodeManager.nodeClients)))
i.eventChan = i.session.WatchServices(typeutil.IndexNodeRole, revision+1)