From 3fb9334b7dd0cd9e412b26b12183a06ae768dc2d Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Wed, 31 May 2023 17:07:29 +0800 Subject: [PATCH] Make binlog size metric to collect healthy binlog only (#24558) Signed-off-by: bigsheeper --- internal/datacoord/meta.go | 4 ++-- internal/metrics/datacoord_metrics.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/datacoord/meta.go b/internal/datacoord/meta.go index 696525128..1187d66fc 100644 --- a/internal/datacoord/meta.go +++ b/internal/datacoord/meta.go @@ -251,9 +251,9 @@ func (m *meta) GetCollectionBinlogSize() (int64, map[UniqueID]int64) { if isSegmentHealthy(segment) { total += segmentSize collectionBinlogSize[segment.GetCollectionID()] += segmentSize + metrics.DataCoordStoredBinlogSize.WithLabelValues( + fmt.Sprint(segment.GetCollectionID()), fmt.Sprint(segment.GetID())).Set(float64(segmentSize)) } - metrics.DataCoordStoredBinlogSize.WithLabelValues( - fmt.Sprint(segment.GetCollectionID()), fmt.Sprint(segment.GetID())).Set(float64(segmentSize)) } return total, collectionBinlogSize } diff --git a/internal/metrics/datacoord_metrics.go b/internal/metrics/datacoord_metrics.go index 9a5410a5a..e5dff1c90 100644 --- a/internal/metrics/datacoord_metrics.go +++ b/internal/metrics/datacoord_metrics.go @@ -95,7 +95,7 @@ var ( Namespace: milvusNamespace, Subsystem: typeutil.DataCoordRole, Name: "stored_binlog_size", - Help: "binlog size of segments", + Help: "binlog size of healthy segments", }, []string{ collectionIDLabelName, segmentIDLabelName, -- GitLab