diff --git a/storage/metric/leveldb.go b/storage/metric/leveldb.go index 7de237e17..09f27e3c9 100644 --- a/storage/metric/leveldb.go +++ b/storage/metric/leveldb.go @@ -506,7 +506,7 @@ func (l *LevelDBMetricPersistence) refreshHighWatermarks(groups map[model.Finger } // BUG(matt): Repace this with watermark management. - if !newestSampleTimestamp.Before(time.Unix(value.GetTimestamp(), 0)) { + if newestSampleTimestamp.After(time.Unix(value.GetTimestamp(), 0)) { value.Timestamp = proto.Int64(newestSampleTimestamp.Unix()) batch.Put(fingerprint.ToDTO(), value) }