Skip to content

Commit

Permalink
Merge branch 'main' into mtocker-fix-all-changes-not-flushed
Browse files Browse the repository at this point in the history
  • Loading branch information
morgo authored Jul 31, 2024
2 parents f201252 + 7a357a6 commit e523cbe
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion pkg/throttler/mysql80replica.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

0 comments on commit e523cbe

Please sign in to comment.