diff --git a/go/vt/vttablet/tabletmanager/replmanager.go b/go/vt/vttablet/tabletmanager/replmanager.go index 1ef616c3e8..64da755030 100644 --- a/go/vt/vttablet/tabletmanager/replmanager.go +++ b/go/vt/vttablet/tabletmanager/replmanager.go @@ -105,7 +105,7 @@ func (rm *replManager) check() { func (rm *replManager) checkActionLocked() { status, err := rm.tm.MysqlDaemon.ReplicationStatus() if err != nil { - if err != mysql.ErrNotReplica { + if mysql.NewSQLErrorFromError(err) != mysql.ErrNotReplica { return } log.Infof("slack error: check replication status failed with %v", err)