From 3f9c5baf638c6d1e8115ee4f11ecacabda1e7ad8 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 12 Nov 2021 19:17:50 +0800 Subject: [PATCH] [skip ci] Add comment for startCollectionFlowGraph (#11735) Signed-off-by: bigsheeper --- internal/querynode/data_sync_service.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/data_sync_service.go b/internal/querynode/data_sync_service.go index 90eb76ec52..660ae900dd 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -138,6 +138,7 @@ func (dsService *dataSyncService) getCollectionDeltaFlowGraphs(collectionID Uniq return tmpFGs, nil } +// startCollectionFlowGraph starts the collection flow graph by collectionID func (dsService *dataSyncService) startCollectionFlowGraph(collectionID UniqueID, vChannels []string) error { dsService.mu.Lock() defer dsService.mu.Unlock()