diff --git a/pkg/throttler/mysql80replica.go b/pkg/throttler/mysql80replica.go index 3089eb0..dacf95e 100644 --- a/pkg/throttler/mysql80replica.go +++ b/pkg/throttler/mysql80replica.go @@ -76,7 +76,7 @@ func (l *MySQL80Replica) UpdateLag() error { } atomic.StoreInt64(&l.currentLagInMs, newLagValue) if l.IsThrottled() { - l.logger.Warnf("replication delayed, throttling in progress. lag: %v tolerance: %v", + l.logger.Warnf("replication delayed, throttling in progress. lag: %v tolerance: %v", atomic.LoadInt64(&l.currentLagInMs), l.lagTolerance) } return nil