diff --git a/dm/_utils/terror_gen/errors_release.txt b/dm/_utils/terror_gen/errors_release.txt
index 83d249d5b4..1f3a74a5e0 100644
--- a/dm/_utils/terror_gen/errors_release.txt
+++ b/dm/_utils/terror_gen/errors_release.txt
@@ -361,7 +361,7 @@ ErrSyncerOperatorNotExist,[code=36065:class=sync-unit:scope=internal:level=low],
 ErrSyncerEventNotExist,[code=36066:class=sync-unit:scope=internal:level=high], "Message: replace or inject event not exist, location: %s"
 ErrSyncerParseDDL,[code=36067:class=sync-unit:scope=internal:level=high], "Message: parse DDL: %s, Workaround: Please confirm your DDL statement is correct and needed. For TiDB compatible DDL, see https://docs.pingcap.com/tidb/stable/mysql-compatibility#ddl-operations. You can use `handle-error` command to skip or replace the DDL or add a binlog filter rule to ignore it if the DDL is not needed."
 ErrSyncerUnsupportedStmt,[code=36068:class=sync-unit:scope=internal:level=high], "Message: `%s` statement not supported in %s mode"
-ErrSyncerGetEvent,[code=36069:class=sync-unit:scope=upstream:level=high], "Message: get binlog event error: %v, Workaround: Please check if the binlog file could be parsed by `mysqlbinlog`."
+ErrSyncerGetEvent,[code=36069:class=sync-unit:scope=upstream:level=high], "Message: get binlog event error: %v, Workaround: Please check if the binlog file could be parsed by `mysqlbinlog` or `mariadb-binlog`."
 ErrSyncerDownstreamTableNotFound,[code=36070:class=sync-unit:scope=internal:level=high], "Message: downstream table %s not found"
 ErrSyncerCancelledDDL,[code=11129:class=sync-unit:scope=internal:level=high], "Message: DDL %s executed in background and met error, Workaround: Please manually check the error from TiDB and handle it."
 ErrSyncerReprocessWithSafeModeFail,[code=36071:class=sync-unit:scope=internal:level=medium], "Message: your `safe-mode-duration` in task.yaml is set to 0s, the task can't be re-processed without safe mode currently, Workaround: Please stop and re-start this task. If you want to start task successfully, you need set `safe-mode-duration` greater than `0s`."
diff --git a/dm/checker/checker.go b/dm/checker/checker.go
index 445e4929d4..fab5c5f871 100644
--- a/dm/checker/checker.go
+++ b/dm/checker/checker.go
@@ -374,6 +374,12 @@ func (c *Checker) Init(ctx context.Context) (err error) {
 			if _, ok := c.checkingItems[config.BinlogDBChecking]; ok {
 				c.checkList = append(c.checkList, checker.NewBinlogDBChecker(instance.sourceDB, instance.sourceDBinfo, info.sourceID2InterestedDB[i], instance.cfg.CaseSensitive))
 			}
+
+			if strings.Contains(instance.sourceDB.Version, "MariaDB") {
+				if _, ok := c.checkingItems[config.BinlogLegacyEventPosChecking]; ok {
+					c.checkList = append(c.checkList, checker.NewMariaDBBinlogLegacyEventPosChecker(instance.sourceDB.DB, instance.sourceDBinfo))
+				}
+			}
 		}
 	}
 
diff --git a/dm/config/checking_item.go b/dm/config/checking_item.go
index 777548b67c..8be842db3e 100644
--- a/dm/config/checking_item.go
+++ b/dm/config/checking_item.go
@@ -30,6 +30,7 @@ const (
 	BinlogEnableChecking         = "binlog_enable"
 	BinlogFormatChecking         = "binlog_format"
 	BinlogRowImageChecking       = "binlog_row_image"
+	BinlogLegacyEventPosChecking = "binlog_legacy_event_pos"
 	TableSchemaChecking          = "table_schema"
 	ShardTableSchemaChecking     = "schema_of_shard_tables"
 	ShardAutoIncrementIDChecking = "auto_increment_ID"
@@ -63,6 +64,7 @@ var AllCheckingItems = map[string]string{
 	BinlogEnableChecking:         "binlog enable checking item",
 	BinlogFormatChecking:         "binlog format checking item",
 	BinlogRowImageChecking:       "binlog row image checking item",
+	BinlogLegacyEventPosChecking: "binlog legacy event pos checking item",
 	TableSchemaChecking:          "table schema compatibility checking item",
 	ShardTableSchemaChecking:     "consistent schema of shard tables checking item",
 	ShardAutoIncrementIDChecking: "conflict auto increment ID of shard tables checking item",
diff --git a/dm/errors.toml b/dm/errors.toml
index f2568595e2..c00bb1810b 100644
--- a/dm/errors.toml
+++ b/dm/errors.toml
@@ -2185,7 +2185,7 @@ tags = ["internal", "high"]
 [error.DM-sync-unit-36069]
 message = "get binlog event error: %v"
 description = ""
-workaround = "Please check if the binlog file could be parsed by `mysqlbinlog`."
+workaround = "Please check if the binlog file could be parsed by `mysqlbinlog` or `mariadb-binlog`."
 tags = ["upstream", "high"]
 
 [error.DM-sync-unit-36070]
diff --git a/dm/pkg/checker/binlog.go b/dm/pkg/checker/binlog.go
index b3b4e8ed89..43cf2c36aa 100644
--- a/dm/pkg/checker/binlog.go
+++ b/dm/pkg/checker/binlog.go
@@ -105,7 +105,7 @@ func (pc *MySQLBinlogFormatChecker) Check(ctx context.Context) *Result {
 	}
 	if strings.ToUpper(value) != "ROW" {
 		result.Errors = append(result.Errors, NewError("binlog_format is %s, and should be ROW", value))
-		result.Instruction = "MySQL as source: please execute 'set global binlog_format=ROW;'; AWS Aurora (MySQL)/RDS MySQL as source: please refer to the document to create a new DB parameter group and set the binlog_format=row: https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/USER_WorkingWithDBInstanceParamGroups.html. Then modify the instance to use the new DB parameter group and restart the instance to take effect."
+		result.Instruction = "MySQL or MariaDB as source: please execute 'SET GLOBAL binlog_format=ROW;'; AWS Aurora (MySQL)/RDS MySQL as source: please refer to the document to create a new DB parameter group and set the binlog_format=row: https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/USER_WorkingWithDBInstanceParamGroups.html. Then modify the instance to use the new DB parameter group and restart the instance to take effect."
 		return result
 	}
 	result.State = StateSuccess
@@ -195,6 +195,71 @@ func (pc *MySQLBinlogRowImageChecker) Name() string {
 	return "mysql_binlog_row_image"
 }
 
+/*****************************************************/
+
+var mariaDBBinlogLegacyEventPosCheckingRequired MySQLVersion = [3]uint{11, 4, 0}
+
+// MariaDBBinlogLegacyEventPosChecker checks mysql binlog_format.
+type MariaDBBinlogLegacyEventPosChecker struct {
+	db     *sql.DB
+	dbinfo *dbutil.DBConfig
+}
+
+// NewMariaDBBinlogLegacyEventPosChecker returns a RealChecker.
+func NewMariaDBBinlogLegacyEventPosChecker(db *sql.DB, dbinfo *dbutil.DBConfig) RealChecker {
+	return &MariaDBBinlogLegacyEventPosChecker{db: db, dbinfo: dbinfo}
+}
+
+// Check implements the RealChecker interface.
+func (pc *MariaDBBinlogLegacyEventPosChecker) Check(ctx context.Context) *Result {
+	result := &Result{
+		Name:  pc.Name(),
+		Desc:  "check whether mariadb binlog_legacy_event_pos is ON",
+		State: StateFailure,
+		Extra: fmt.Sprintf("address of db instance - %s:%d", pc.dbinfo.Host, pc.dbinfo.Port),
+	}
+
+	// check version firstly
+	value, err := dbutil.ShowVersion(ctx, pc.db)
+	if err != nil {
+		markCheckError(result, err)
+		return result
+	}
+
+	version, err := toMySQLVersion(value)
+	if err != nil {
+		markCheckError(result, err)
+		return result
+	}
+
+	// for mariadb.version < 11.4,  we don't need to check binlog_legacy_event_pos
+	if conn.IsMariaDB(value) && !version.Ge(mariaDBBinlogLegacyEventPosCheckingRequired) {
+		result.State = StateSuccess
+		return result
+	}
+
+	value, err = dbutil.ShowMySQLVariable(ctx, pc.db, "binlog_legacy_event_pos")
+	if err != nil {
+		markCheckError(result, err)
+		return result
+	}
+	if strings.ToUpper(value) != "ON" {
+		result.Errors = append(result.Errors, NewError("binlog_legacy_event_pos is %s, and should be ON", value))
+		result.Instruction = "MariaDB 11.4 and newer as source: please execute 'SET GLOBAL binlog_legacy_event_pos=ON;' or update the configuration and apply the configuration. You also need to start replicating from a binlog position that was created after chaning this setting."
+		return result
+	}
+	result.State = StateSuccess
+
+	return result
+}
+
+// Name implements the RealChecker interface.
+func (pc *MariaDBBinlogLegacyEventPosChecker) Name() string {
+	return "mariadb_binlog_legacy_event_pos"
+}
+
+/*****************************************************/
+
 // BinlogDBChecker checks if migrated dbs are in binlog_do_db or binlog_ignore_db.
 type BinlogDBChecker struct {
 	db            *conn.BaseDB
diff --git a/dm/pkg/terror/error_list.go b/dm/pkg/terror/error_list.go
index 4da1669d2a..87db68a3c1 100644
--- a/dm/pkg/terror/error_list.go
+++ b/dm/pkg/terror/error_list.go
@@ -1166,7 +1166,7 @@ var (
 	ErrSyncerEventNotExist                  = New(codeSyncerEventNotExist, ClassSyncUnit, ScopeInternal, LevelHigh, "replace or inject event not exist, location: %s", "")
 	ErrSyncerParseDDL                       = New(codeSyncerParseDDL, ClassSyncUnit, ScopeInternal, LevelHigh, "parse DDL: %s", "Please confirm your DDL statement is correct and needed. For TiDB compatible DDL, see https://docs.pingcap.com/tidb/stable/mysql-compatibility#ddl-operations. You can use `handle-error` command to skip or replace the DDL or add a binlog filter rule to ignore it if the DDL is not needed.")
 	ErrSyncerUnsupportedStmt                = New(codeSyncerUnsupportedStmt, ClassSyncUnit, ScopeInternal, LevelHigh, "`%s` statement not supported in %s mode", "")
-	ErrSyncerGetEvent                       = New(codeSyncerGetEvent, ClassSyncUnit, ScopeUpstream, LevelHigh, "get binlog event error: %v", "Please check if the binlog file could be parsed by `mysqlbinlog`.")
+	ErrSyncerGetEvent                       = New(codeSyncerGetEvent, ClassSyncUnit, ScopeUpstream, LevelHigh, "get binlog event error: %v", "Please check if the binlog file could be parsed by `mysqlbinlog` or `mariadb-binlog`.")
 	ErrSyncerDownstreamTableNotFound        = New(codeSyncerDownstreamTableNotFound, ClassSyncUnit, ScopeInternal, LevelHigh, "downstream table %s not found", "")
 	ErrSyncerCancelledDDL                   = New(codeSyncerCancelledDDL, ClassSyncUnit, ScopeInternal, LevelHigh, "DDL %s executed in background and met error", "Please manually check the error from TiDB and handle it.")
 	ErrSyncerReprocessWithSafeModeFail      = New(codeSyncerReprocessWithSafeModeFail, ClassSyncUnit, ScopeInternal, LevelMedium, "your `safe-mode-duration` in task.yaml is set to 0s, the task can't be re-processed without safe mode currently", "Please stop and re-start this task. If you want to start task successfully, you need set `safe-mode-duration` greater than `0s`.")