diff --git a/physical/mysql/mysql.go b/physical/mysql/mysql.go index af666b5d6c..db078af5d2 100644 --- a/physical/mysql/mysql.go +++ b/physical/mysql/mysql.go @@ -621,9 +621,9 @@ func (i *MySQLLock) becomeLeader() error { func (i *MySQLLock) Lock() error { defer metrics.MeasureSince([]string{"mysql", "get_lock"}, time.Now()) - // Lock timeout math.MaxUint32 instead of -1 solves compatibility issues with + // Lock timeout math.MaxInt32 instead of -1 solves compatibility issues with // different MySQL flavours i.e. MariaDB - rows, err := i.in.Query("SELECT GET_LOCK(?, ?), IS_USED_LOCK(?)", i.key, math.MaxUint32, i.key) + rows, err := i.in.Query("SELECT GET_LOCK(?, ?), IS_USED_LOCK(?)", i.key, math.MaxInt32, i.key) if err != nil { return err }