From 6e22d079eedf548e736f10d5557c109cf730ee6b Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Tue, 16 Nov 2021 21:36:03 +0800 Subject: [PATCH] [skip ci] Add comment for removeCollectionDeltaFlowGraph (#11928) 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 1cb33eecfa..e8c88c5f10 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -189,6 +189,7 @@ func (dsService *dataSyncService) removeCollectionFlowGraph(collectionID UniqueI delete(dsService.collectionFlowGraphs, collectionID) } +// removeCollectionDeltaFlowGraph would remove the collection delta flow graph by collectionID func (dsService *dataSyncService) removeCollectionDeltaFlowGraph(collectionID UniqueID) { dsService.mu.Lock() defer dsService.mu.Unlock()