diff --git a/internal/metrics/querynode_metrics.go b/internal/metrics/querynode_metrics.go index dd2cbbd7fb..3f863f4bb5 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 e8b783e1e6..de6d738e4c 100644 --- a/internal/querynode/meta_replica.go +++ b/internal/querynode/meta_replica.go @@ -631,7 +631,8 @@ func (replica *metaReplica) addSegmentPrivate(segment *Segment) error { fmt.Sprint(Params.QueryNodeCfg.GetNodeID()), fmt.Sprint(segment.collectionID), fmt.Sprint(segment.partitionID), - string(segType), + segType.String(), + fmt.Sprint(segment.indexedFieldInfos.Len()), ).Add(float64(rowCount)) } return nil @@ -739,7 +740,8 @@ func (replica *metaReplica) removeSegmentPrivate(segmentID UniqueID, segType seg fmt.Sprint(Params.QueryNodeCfg.GetNodeID()), fmt.Sprint(segment.collectionID), fmt.Sprint(segment.partitionID), - string(segType), + segType.String(), + fmt.Sprint(segment.indexedFieldInfos.Len()), ).Sub(float64(rowCount)) } } diff --git a/internal/querynode/segment.go b/internal/querynode/segment.go index 8e878051ed..47827854f3 100644 --- a/internal/querynode/segment.go +++ b/internal/querynode/segment.go @@ -709,6 +709,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