[skip ci] Add comment for startPartitionFlowGraph (#12026)

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

+// startPartitionFlowGraph would start the partition flow graph
 func (dsService *dataSyncService) startPartitionFlowGraph(partitionID UniqueID, vChannels []string) error {
 	dsService.mu.Lock()
 	defer dsService.mu.Unlock()