diff --git a/storage/metric/processor.go b/storage/metric/processor.go index b1abc606b..7e289be11 100644 --- a/storage/metric/processor.go +++ b/storage/metric/processor.go @@ -135,6 +135,9 @@ func (p *CompactionProcessor) Apply(sampleIterator leveldb.Iterator, samplesPers return } sampleKey.Load(sampleKeyDto) + if !sampleKey.Fingerprint.Equal(fingerprint) { + break + } unactedSamples, err = extractSampleValues(sampleIterator) if err != nil {