admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 17:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: dirty querynode doesn't clean up after restart (#43909)

Browse Source 
issue: #43905

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
This commit is contained in:
wei liu 2025-08-18 18:05:46 +08:00 committed by GitHub
parent 9a31d88d49
commit dada00a81c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/querycoordv2/server.go
View File

@ -469,12 +469,10 @@ func (s *Server) startQueryCoord() error {
return err
}
if len(sessions) > 0 {
log.Info("rewatch nodes", zap.Any("sessions", sessions))
err = s.rewatchNodes(sessions)
if err != nil {
return err
}
log.Info("rewatch nodes", zap.Any("sessions", sessions))
err = s.rewatchNodes(sessions)
if err != nil {
return err
}
s.wg.Add(1)

2
internal/querycoordv2/server_test.go
View File

@ -761,7 +761,7 @@ func TestRewatchNodesWithEmptySessions(t *testing.T) {
defer mockHandleNodeDown.UnPatch()
// Act: Call rewatchNodes with empty sessions
err := server.rewatchNodes(map[string]*sessionutil.Session{})
err := server.rewatchNodes(nil)
// Assert: All nodes should be removed
assert.NoError(t, err)