diff --git a/compactor/periodic.go b/compactor/periodic.go index 447352ec3beb..705a256b7acc 100644 --- a/compactor/periodic.go +++ b/compactor/periodic.go @@ -86,6 +86,10 @@ func (t *Periodic) Run() { } plog.Noticef("Starting auto-compaction at revision %d (retention: %v)", rev, t.period) _, err := t.c.Compact(t.ctx, &pb.CompactionRequest{Revision: rev}) + + // update the last compaction time + last = clock.Now() + if err == nil || err == mvcc.ErrCompacted { t.revs = remaining plog.Noticef("Finished auto-compaction at revision %d", rev)