Merge pull request #2116 from prometheus/beorn7/fix
Add guard against non-monotonic samples in series
This commit is contained in:
commit
c1ae61a2cc
|
@ -14,6 +14,7 @@
|
||||||
package local
|
package local
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"sort"
|
"sort"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
@ -496,6 +497,10 @@ func (s *memorySeries) preloadChunksForRange(
|
||||||
if throughIdx == len(s.chunkDescs) {
|
if throughIdx == len(s.chunkDescs) {
|
||||||
throughIdx--
|
throughIdx--
|
||||||
}
|
}
|
||||||
|
if fromIdx > throughIdx {
|
||||||
|
// Guard against nonsensical result. The caller will quarantine the series with a meaningful log entry.
|
||||||
|
return nopIter, fmt.Errorf("fromIdx=%d is greater than throughIdx=%d, likely caused by data corruption", fromIdx, throughIdx)
|
||||||
|
}
|
||||||
|
|
||||||
pinIndexes := make([]int, 0, throughIdx-fromIdx+1)
|
pinIndexes := make([]int, 0, throughIdx-fromIdx+1)
|
||||||
for i := fromIdx; i <= throughIdx; i++ {
|
for i := fromIdx; i <= throughIdx; i++ {
|
||||||
|
|
Loading…
Reference in New Issue