diff --git a/internal/metrics/querynode_metrics.go b/internal/metrics/querynode_metrics.go index dd2cbbd7fb1d2695d75c7513ce0af6b8853b0dc0..3f863f4bb576394df688850c0aabdd5fd0f9afaa 100644 --- a/internal/metrics/querynode_metrics.go +++ b/internal/metrics/querynode_metrics.go @@ -323,6 +323,7 @@ var ( collectionIDLabelName, partitionIDLabelName, segmentStateLabelName, + indexCountLabelName, }) // QueryNodeConsumeCounter counts the bytes QueryNode consumed from message storage. diff --git a/internal/querynode/meta_replica.go b/internal/querynode/meta_replica.go index b477aab590b2985c68204e9f2989335ac21496f4..72c22b2e0229c7783c21c3b2452c4c7a81b3b14f 100644 --- a/internal/querynode/meta_replica.go +++ b/internal/querynode/meta_replica.go @@ -634,6 +634,7 @@ func (replica *metaReplica) addSegmentPrivate(segment *Segment) error { fmt.Sprint(segment.collectionID), fmt.Sprint(segment.partitionID), segType.String(), + fmt.Sprint(segment.indexedFieldInfos.Len()), ).Add(float64(rowCount)) } return nil @@ -742,6 +743,7 @@ func (replica *metaReplica) removeSegmentPrivate(segmentID UniqueID, segType seg fmt.Sprint(segment.collectionID), fmt.Sprint(segment.partitionID), segType.String(), + fmt.Sprint(segment.indexedFieldInfos.Len()), ).Sub(float64(rowCount)) } } diff --git a/internal/querynode/segment.go b/internal/querynode/segment.go index 61ab6548421b3777cbd699e220cb2fa136a66f7d..b9b3706849fef4f27f5364027a053c217b2a731e 100644 --- a/internal/querynode/segment.go +++ b/internal/querynode/segment.go @@ -713,6 +713,7 @@ func (s *Segment) segmentInsert(offset int64, entityIDs []UniqueID, timestamps [ fmt.Sprint(s.collectionID), fmt.Sprint(s.partitionID), s.segmentType.String(), + fmt.Sprint(0), ).Add(float64(numOfRow)) s.setRecentlyModified(true) return nil