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

fix: handle the error and return in mixcoord (#42152)

Browse Source 
fix: handle the error and return in mixcoord
issue:https://github.com/milvus-io/milvus/issues/42151

Signed-off-by: Xianhui.Lin <xianhui.lin@zilliz.com>
This commit is contained in:
Xianhui Lin 2025-05-29 11:40:30 +08:00 committed by GitHub
parent 2ae4d80120
commit 8bbfbd1d54
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
internal/coordinator/mix_coord.go
View File

@ -125,8 +125,7 @@ func (s *mixCoordImpl) Register() error {
func (s *mixCoordImpl) Init() error {
log := log.Ctx(s.ctx)
var initErr error
if err := s.initSession(); err != nil {
initErr = err
if initErr = s.initSession(); initErr != nil {
return initErr
}
s.factory.Init(Params)
@ -151,10 +150,9 @@ func (s *mixCoordImpl) Init() error {
s.UpdateStateCode(commonpb.StateCode_StandBy)
log.Info("MixCoord enter standby mode successfully")
} else {
var err error
s.initOnce.Do(func() {
if err = s.initInternal(); err != nil {
log.Error("mixCoord init failed", zap.Error(err))
if initErr = s.initInternal(); initErr != nil {
log.Error("mixCoord init failed", zap.Error(initErr))
}
})
}
@ -178,7 +176,7 @@ func (s *mixCoordImpl) initInternal() error {
}
if err := s.streamingCoord.Start(s.ctx); err != nil {
log.Error("streamCoord init failed", zap.Error(err))
log.Error("streamCoord start failed", zap.Error(err))
return err
}
@ -188,7 +186,7 @@ func (s *mixCoordImpl) initInternal() error {
}
if err := s.datacoordServer.Start(); err != nil {
log.Error("dataCoord init failed", zap.Error(err))
log.Error("dataCoord start failed", zap.Error(err))
return err
}
@ -198,7 +196,7 @@ func (s *mixCoordImpl) initInternal() error {
}
if err := s.queryCoordServer.Start(); err != nil {
log.Error("queryCoord init failed", zap.Error(err))
log.Error("queryCoord start failed", zap.Error(err))
return err
}
return nil