milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: datanode L0 segment num wrong (#29050) 

relate:  https://github.com/milvus-io/milvus/issues/27675

Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
pull/29034/head
aoiasd 2023-12-20 11:20:44 +08:00 committed by GitHub
parent cbf0f9c527
commit 010d8362ad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/datacoord/meta.go
View File

@ -116,7 +116,7 @@ func (m *meta) reloadFromKV() error {
numStoredRows := int64(0) numStoredRows := int64(0)
for _, segment := range segments { for _, segment := range segments {
m.segments.SetSegment(segment.ID, NewSegmentInfo(segment)) m.segments.SetSegment(segment.ID, NewSegmentInfo(segment))
metrics.DataCoordNumSegments.WithLabelValues(segment.State.String(), segment.GetLevel().String()).Inc() metrics.DataCoordNumSegments.WithLabelValues(segment.GetState().String(), segment.GetLevel().String()).Inc()
if segment.State == commonpb.SegmentState_Flushed { if segment.State == commonpb.SegmentState_Flushed {
numStoredRows += segment.NumOfRows numStoredRows += segment.NumOfRows
@ -481,6 +481,7 @@ func CreateL0Operator(collectionID, partitionID, segmentID int64, channel string
Level: datapb.SegmentLevel_L0, Level: datapb.SegmentLevel_L0,
}, },
} }
modPack.metricMutation.addNewSeg(commonpb.SegmentState_Growing, datapb.SegmentLevel_L0, 0)
} }
return true return true
} }

2
internal/datacoord/services.go
View File

@ -503,7 +503,7 @@ func (s *Server) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPath
if req.GetFlushed() { if req.GetFlushed() {
if req.GetSegLevel() == datapb.SegmentLevel_L0 { if req.GetSegLevel() == datapb.SegmentLevel_L0 {
metrics.DataCoordSizeStoredL0Segment.WithLabelValues().Observe(calculateL0SegmentSize(req.GetField2StatslogPaths())) metrics.DataCoordSizeStoredL0Segment.WithLabelValues(fmt.Sprint(req.GetCollectionID())).Observe(calculateL0SegmentSize(req.GetField2StatslogPaths()))
metrics.DataCoordRateStoredL0Segment.WithLabelValues().Inc() metrics.DataCoordRateStoredL0Segment.WithLabelValues().Inc()
} else { } else {
// because segmentMananger only manage growing segment // because segmentMananger only manage growing segment

9
pkg/metrics/datacoord_metrics.go
View File

@ -75,15 +75,18 @@ var (
prometheus.HistogramOpts{ prometheus.HistogramOpts{
Namespace: milvusNamespace, Namespace: milvusNamespace,
Subsystem: typeutil.DataCoordRole, Subsystem: typeutil.DataCoordRole,
Name: "store_l0_segment_size", Name: "store_level0_segment_size",
Help: "stored l0 segment size", Help: "stored l0 segment size",
}, []string{}) Buckets: buckets,
}, []string{
collectionIDLabelName,
})
DataCoordRateStoredL0Segment = prometheus.NewCounterVec( DataCoordRateStoredL0Segment = prometheus.NewCounterVec(
prometheus.CounterOpts{ prometheus.CounterOpts{
Namespace: milvusNamespace, Namespace: milvusNamespace,
Subsystem: typeutil.DataCoordRole, Subsystem: typeutil.DataCoordRole,
Name: "store_l0_segment_rate", Name: "store_level0_segment_rate",
Help: "stored l0 segment rate", Help: "stored l0 segment rate",
}, []string{}) }, []string{})