mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-16 18:17:35 +02:00
Code Issues Projects Releases Wiki Activity

remove unnecessary change to how we check if series labels were present

Browse Source 
in local cache

Signed-off-by: Callum Styan <callumstyan@gmail.com>
This commit is contained in:
Callum Styan 2024-09-17 10:50:16 -07:00
parent 271cffddf5
commit 7da79a238f
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
storage/remote/queue_manager.go
View File

@ -702,8 +702,8 @@ outer:
continue
}
t.seriesMtx.Lock()
lbls := t.seriesLabels[s.Ref]
if lbls.Len() == 0 {
lbls, ok := t.seriesLabels[s.Ref]
if !ok {
t.dataDropped.incr(1)
if _, ok := t.droppedSeries[s.Ref]; !ok {
level.Info(t.logger).Log("msg", "Dropped sample for series that was not explicitly dropped via relabelling", "ref", s.Ref)
@ -764,8 +764,8 @@ outer:
continue
}
t.seriesMtx.Lock()
lbls := t.seriesLabels[e.Ref]
if lbls.Len() == 0 {
lbls, ok := t.seriesLabels[e.Ref]
if !ok {
// Track dropped exemplars in the same EWMA for sharding calc.
t.dataDropped.incr(1)
if _, ok := t.droppedSeries[e.Ref]; !ok {
@ -821,8 +821,8 @@ outer:
continue
}
t.seriesMtx.Lock()
lbls := t.seriesLabels[h.Ref]
if lbls.Len() == 0 {
lbls, ok := t.seriesLabels[h.Ref]
if !ok {
t.dataDropped.incr(1)
if _, ok := t.droppedSeries[h.Ref]; !ok {
level.Info(t.logger).Log("msg", "Dropped histogram for series that was not explicitly dropped via relabelling", "ref", h.Ref)
@ -876,8 +876,8 @@ outer:
continue
}
t.seriesMtx.Lock()
lbls := t.seriesLabels[h.Ref]
if lbls.Len() == 0 {
lbls, ok := t.seriesLabels[h.Ref]
if !ok {
t.dataDropped.incr(1)
if _, ok := t.droppedSeries[h.Ref]; !ok {
level.Info(t.logger).Log("msg", "Dropped histogram for series that was not explicitly dropped via relabelling", "ref", h.Ref)