Fix chunk corruption compaction bug.

This fixes part 1) of #367 (the storing of samples with the wrong fingerprint into a compacted chunk, thus corrupting it). Change-Id: I4c36d0d2e508e37a0aba90b8ca2ecc78ee03e3f1
prometheus · Oct 21, 2013 · a1a97ed · a1a97ed
1 parent a50ee8d
commit a1a97ed
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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 {