From 315d468b49e199f12f1aff996fd7fe05ea817f61 Mon Sep 17 00:00:00 2001 From: wei liu Date: Fri, 31 Mar 2023 14:12:23 +0800 Subject: [PATCH] fix fg metrics (#23139) Signed-off-by: Wei Liu --- 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 1d5841a30c..c0cc544778 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -281,6 +281,7 @@ func (dsService *dataSyncService) removeEmptyFlowGraphByChannel(collectionID int dsService.metaReplica.removeCollectionVDeltaChannel(collectionID, dc) // close flowgraph first, so no write will be dispatched to tSafeReplica fg.close() + metrics.QueryNodeNumFlowGraphs.WithLabelValues(fmt.Sprint(Params.QueryNodeCfg.GetNodeID())).Dec() dsService.tSafeReplica.removeTSafe(dc) // try best to remove, it's ok if all info is gone before this call rateCol.removeTSafeChannel(dc)