diff --git a/internal/table/table.go b/internal/table/table.go index 46a5021..d290d52 100644 --- a/internal/table/table.go +++ b/internal/table/table.go @@ -446,12 +446,12 @@ func withRetries(retryCount int, fn func() error) (err error) { func mysqlRetryInterval(err error) time.Duration { if ok, myerr := my.Error(err); ok { // MySQL error - if my.CanRetry(myerr) { - return time.Second - } if my.MySQLErrorCode(err) == 1213 { // deadlock return time.Millisecond * 10 } + if my.CanRetry(myerr) { + return time.Second + } } return 0 }