mysql(ticdc): remove error filter when check isTiDB in backend init (#…

…11214) (#11261) close #11213
pingcap · Jun 11, 2024 · 2a28078 · 2a28078
1 parent 2425d54
commit 2a28078
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/pkg/sink/mysql/db_helper.go b/pkg/sink/mysql/db_helper.go
@@ -318,12 +318,7 @@ func CheckIsTiDB(ctx context.Context, db *sql.DB) (bool, error) {
 	err := row.Scan(&tidbVer)
 	if err != nil {
 		log.Error("check tidb version error", zap.Error(err))
-		// downstream is not TiDB, do nothing
-		if mysqlErr, ok := errors.Cause(err).(*dmysql.MySQLError); ok && (mysqlErr.Number == tmysql.ErrNoDB ||
-			mysqlErr.Number == tmysql.ErrSpDoesNotExist || mysqlErr.Number == tmysql.ErrDBaccessDenied) {
-			return false, nil
-		}
-		return false, errors.Trace(err)
+		return false, nil
 	}
 	return true, nil
 }