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: save current target after target observer stop (#31333)

Browse Source 
issue: #28491
pr: #31315

should save target to meta store after target observer stop, incase of
target changed

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
This commit is contained in:
wei liu 2024-03-18 13:49:11 +08:00 committed by GitHub
parent 85a1b6c96e
commit 3987cd69d7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/querycoordv2/server.go
View File

@ -459,11 +459,6 @@ func (s *Server) startServerLoop() {
}
func (s *Server) Stop() error {
// save target to meta store, after querycoord restart, make it fast to recover current target
if s.targetMgr != nil {
s.targetMgr.SaveCurrentTarget(s.store)
}
// FOLLOW the dependence graph:
// job scheduler -> checker controller -> task scheduler -> dist controller -> cluster -> session
// observers -> dist controller
@ -490,6 +485,13 @@ func (s *Server) Stop() error {
if s.targetObserver != nil {
s.targetObserver.Stop()
}
// save target to meta store, after querycoord restart, make it fast to recover current target
// should save target after target observer stop, incase of target changed
if s.targetMgr != nil {
s.targetMgr.SaveCurrentTarget(s.store)
}
if s.replicaObserver != nil {
s.replicaObserver.Stop()
}