Merge "Fix chunk corruption compaction bug."

2013-10-24 13:57:31 +02:00 · 2013-10-24 13:57:31 +02:00 · 5e18255920
parent 6f6f56021a a1a97ed064
commit 5e18255920
1 changed files with 3 additions and 0 deletions
--- 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 {