admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Check data node error (#9303)

Browse Source 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
This commit is contained in:
godchen 2021-10-07 22:16:56 +08:00 committed by GitHub
parent e4e7c05b3b
commit 445f5426d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
internal/datanode/data_node.go
View File

@ -205,7 +205,10 @@ func (node *DataNode) StartWatchChannels(ctx context.Context) {
log.Warn("Watch channel failed", zap.Error(event.Err()))
// if watch loop return due to event canceled, the datanode is not functional anymore
// stop the datanode and wait for restart
node.Stop()
err := node.Stop()
if err != nil {
log.Warn("node stop failed", zap.Error(err))
}
return
}
for _, evt := range event.Events {
@ -370,7 +373,10 @@ func (node *DataNode) Start() error {
go node.BackGroundGC(node.clearSignal)
go node.session.LivenessCheck(node.ctx, node.liveCh, func() {
node.Stop()
err := node.Stop()
if err != nil {
log.Warn("node stop failed", zap.Error(err))
}
})
Params.CreatedTime = time.Now()
@ -575,7 +581,10 @@ func (node *DataNode) Stop() error {
}
if node.closer != nil {
node.closer.Close()
err := node.closer.Close()
if err != nil {
return err
}
}
return nil
}