[skip ci] Add comment for removePartitionFlowGraph (#12027)

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2021-11-17 20:27:24 +08:00 · 2021-11-17 20:27:24 +08:00 · 7df9600e5d
parent f07b3ff8cb
commit 7df9600e5d
1 changed files with 1 additions and 0 deletions
--- a/internal/querynode/data_sync_service.go
+++ b/internal/querynode/data_sync_service.go
@ -263,6 +263,7 @@ func (dsService *dataSyncService) startPartitionFlowGraph(partitionID UniqueID,
 	return nil
 }

+// removePartitionFlowGraph removes the partition flow graph from dataSyncService by partitionID
 func (dsService *dataSyncService) removePartitionFlowGraph(partitionID UniqueID) {
 	dsService.mu.Lock()
 	defer dsService.mu.Unlock()