upstream/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-25 02:32:17 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

Merge 6411791fa3 into 16034ecf3b

Browse source
This commit is contained in:
KIM KYUNGHWAN 2026-05-04 10:07:41 +12:00 committed by GitHub
commit 8b2d3ea074
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
tsdb/head_wal.go
View file

@ -538,12 +538,22 @@ func (h *Head) resetSeriesWithMMappedChunks(mSeries *memSeries, mmc, oooMmc []*m
}
h.metrics.chunksCreated.Add(float64(len(mmc) + len(oooMmc)))
h.metrics.chunksRemoved.Add(float64(len(mSeries.mmappedChunks)))
h.metrics.chunks.Add(float64(len(mmc) + len(oooMmc) - len(mSeries.mmappedChunks)))
if mSeries.ooo != nil {
h.metrics.chunksRemoved.Add(float64(len(mSeries.ooo.oooMmappedChunks)))
h.metrics.chunks.Sub(float64(len(mSeries.ooo.oooMmappedChunks)))
// During WAL replay with duplicate series records (mSeries.ref != walSeriesRef),
// the old chunks in mSeries may not have been added to the gauge yet,
// so subtracting them would cause the gauge to go negative.
// Only count chunks as removed when we're certain they were previously added.
if mSeries.ref == walSeriesRef {
// Same series ref - old chunks were definitely counted, safe to subtract
h.metrics.chunksRemoved.Add(float64(len(mSeries.mmappedChunks)))
h.metrics.chunks.Add(float64(len(mmc) + len(oooMmc) - len(mSeries.mmappedChunks)))
if mSeries.ooo != nil {
h.metrics.chunksRemoved.Add(float64(len(mSeries.ooo.oooMmappedChunks)))
h.metrics.chunks.Sub(float64(len(mSeries.ooo.oooMmappedChunks)))
}
} else {
// Duplicate series with different ref - old chunks may not have been counted
h.metrics.chunks.Add(float64(len(mmc) + len(oooMmc)))
}
mSeries.mmappedChunks = mmc