diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 633b3d0..2c95e63 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -524,7 +524,7 @@ func (this *Migrator) cutOver() (err error) { currentHeartbeatLag := atomic.LoadInt64(&this.migrationContext.CurrentHeartbeatLag) maxLagMillisecondsThrottleThreshold := atomic.LoadInt64(&this.migrationContext.MaxLagMillisecondsThrottleThreshold) if time.Duration(currentHeartbeatLag) > time.Duration(maxLagMillisecondsThrottleThreshold)*time.Millisecond { - this.migrationContext.Log.Infof("current HeartbeatLag (%.2fs) is too high, it needs to be less than --max-lag-millis (%.2fs) to continue", time.Duration(currentHeartbeatLag).Seconds(), (time.Duration(maxLagMillisecondsThrottleThreshold) * time.Millisecond).Seconds()) + this.migrationContext.Log.Debugf("current HeartbeatLag (%.2fs) is too high, it needs to be less than --max-lag-millis (%.2fs) to continue", time.Duration(currentHeartbeatLag).Seconds(), (time.Duration(maxLagMillisecondsThrottleThreshold) * time.Millisecond).Seconds()) return true, nil } else { return false, nil