diff --git a/pkg/block/fetcher.go b/pkg/block/fetcher.go index a87f74a57a6..700aef952a4 100644 --- a/pkg/block/fetcher.go +++ b/pkg/block/fetcher.go @@ -709,6 +709,7 @@ func (r *ReplicaLabelRemover) Filter(_ context.Context, metas map[ulid.ULID]*met return nil } + countReplicaLabelRemoved := make(map[string]int, len(metas)) for u, meta := range metas { l := make(map[string]string) for n, v := range meta.Thanos.Labels { @@ -717,8 +718,8 @@ func (r *ReplicaLabelRemover) Filter(_ context.Context, metas map[ulid.ULID]*met for _, replicaLabel := range r.replicaLabels { if _, exists := l[replicaLabel]; exists { - level.Debug(r.logger).Log("msg", "replica label removed", "label", replicaLabel) delete(l, replicaLabel) + countReplicaLabelRemoved[replicaLabel] += 1 modified.WithLabelValues(replicaRemovedMeta).Inc() } } @@ -731,6 +732,9 @@ func (r *ReplicaLabelRemover) Filter(_ context.Context, metas map[ulid.ULID]*met nm.Thanos.Labels = l metas[u] = &nm } + for replicaLabelRemoved, count := range countReplicaLabelRemoved { + level.Debug(r.logger).Log("msg", "removed replica label", "label", replicaLabelRemoved, "count", count) + } return nil }