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