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

[skip ci] Add comment for dataSyncService in query node (#8418) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/8436/head
bigsheeper 2021-09-23 21:48:12 +08:00 committed by GitHub
parent a6060e4481
commit 1b7056d3c2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/querynode/data_sync_service.go
View File

@ -204,6 +204,7 @@ func newDataSyncService(ctx context.Context,
}
func (dsService *dataSyncService) close() {
// close collection flow graphs
for _, nodeFGs := range dsService.collectionFlowGraphs {
for _, nodeFG := range nodeFGs {
if nodeFG != nil {
@ -211,6 +212,7 @@ func (dsService *dataSyncService) close() {
}
}
}
// close partition flow graphs
for _, nodeFGs := range dsService.partitionFlowGraphs {
for _, nodeFG := range nodeFGs {
if nodeFG != nil {