diff --git a/posting/mvcc.go b/posting/mvcc.go index 5feeb0e511a..bfe7e1b2a07 100644 --- a/posting/mvcc.go +++ b/posting/mvcc.go @@ -215,10 +215,10 @@ func (ir *incrRollupi) Process(closer *z.Closer, getNewTs func(bool) uint64) { case <-closer.HasBeenClosed(): return case <-cleanupTick.C: - currTs := time.Now().UnixNano() + currTs := time.Now().Unix() for hash, ts := range m { // Remove entries from map which have been there for there more than 10 seconds. - if currTs-ts >= int64(10*time.Second) { + if currTs-ts >= 10 { delete(m, hash) } }