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

fix: unhealthy datacoord started with unhealthy channel manager (#29848) 

issue: #29818

Signed-off-by: chyezh <ye.zhen@zilliz.com>
pull/29665/head
chyezh 2024-01-14 10:36:52 +08:00 committed by GitHub
parent def717af55
commit df5445f18d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/datacoord/server.go
View File

@ -553,7 +553,12 @@ func (s *Server) initServiceDiscovery() error {
datanodes = append(datanodes, info) datanodes = append(datanodes, info)
} }
s.cluster.Startup(s.ctx, datanodes) log.Info("DataCoord Cluster Manager start up")
if err := s.cluster.Startup(s.ctx, datanodes); err != nil {
log.Warn("DataCoord Cluster Manager failed to start up", zap.Error(err))
return err
}
log.Info("DataCoord Cluster Manager start up successfully")
// TODO implement rewatch logic // TODO implement rewatch logic
s.dnEventCh = s.session.WatchServicesWithVersionRange(typeutil.DataNodeRole, r, rev+1, nil) s.dnEventCh = s.session.WatchServicesWithVersionRange(typeutil.DataNodeRole, r, rev+1, nil)