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

Fix replica freeAll order (#17106) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/17109/head
congqixia 2022-05-19 14:53:56 +08:00 committed by GitHub
parent 7eb6fcfb34
commit ae2864639e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/querynode/query_node.go
View File

@ -397,23 +397,19 @@ func (node *QueryNode) Stop() error {
if node.dataSyncService != nil {
node.dataSyncService.close()
}
if node.historical != nil {
node.historical.close()
}
// release streaming first for query/search holds query lock in streaming collection
if node.streaming != nil {
node.streaming.close()
}
/*
if node.queryService != nil {
node.queryService.close()
}*/
if node.historical != nil {
node.historical.close()
}
if node.queryShardService != nil {
node.queryShardService.close()
}
//if node.statsService != nil {
// node.statsService.close()
//}
node.session.Revoke(time.Second)
node.wg.Wait()
return nil