diff --git a/etcdserver/api/v3compactor/periodic.go b/etcdserver/api/v3compactor/periodic.go index 206325fee..fa0d45330 100644 --- a/etcdserver/api/v3compactor/periodic.go +++ b/etcdserver/api/v3compactor/periodic.go @@ -136,13 +136,14 @@ func (pc *Periodic) Run() { zap.Int64("revision", rev), zap.Duration("compact-period", pc.period), ) + startTime := pc.clock.Now() _, err := pc.c.Compact(pc.ctx, &pb.CompactionRequest{Revision: rev}) if err == nil || err == mvcc.ErrCompacted { pc.lg.Info( "completed auto periodic compaction", zap.Int64("revision", rev), zap.Duration("compact-period", pc.period), - zap.Duration("took", time.Since(lastSuccess)), + zap.Duration("took", pc.clock.Now().Sub(startTime)), ) lastSuccess = pc.clock.Now() } else {