From be1602f769fac5e2fb0528cd78f07c097be098b1 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Thu, 18 Nov 2021 09:25:17 +0800 Subject: [PATCH] [skip ci] Add comment for dataSyncService close (#12028) 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 8ef041d690..ebea45a41b 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -303,6 +303,7 @@ func newDataSyncService(ctx context.Context, } } +// close would close and remove all flow graphs in dataSyncService func (dsService *dataSyncService) close() { // close collection flow graphs for _, nodeFGs := range dsService.collectionFlowGraphs {