From be20567852c605046390f1889b35f1381db9429f Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 12 Nov 2021 19:19:50 +0800 Subject: [PATCH] [skip ci] Add comment for removeCollectionFlowGraph (#11737) 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 660ae900dd..1cb33eecfa 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -174,6 +174,7 @@ func (dsService *dataSyncService) startCollectionDeltaFlowGraph(collectionID Uni return nil } +// removeCollectionFlowGraph would remove the collection flow graph by collectionID func (dsService *dataSyncService) removeCollectionFlowGraph(collectionID UniqueID) { dsService.mu.Lock() defer dsService.mu.Unlock()