diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java
index ab23391ac3b..b094d60a30e 100644
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java
@@ -36,7 +36,7 @@ public final class MySqlRecords implements RecordsWithSplitIds<SourceRecords> {
 
     public MySqlRecords(
             @Nullable String splitId,
-            @Nullable Iterator recordsForSplit,
+            @Nullable Iterator<SourceRecords> recordsForSplit,
             Set<String> finishedSnapshotSplits) {
         this.splitId = splitId;
         this.recordsForSplit = recordsForSplit;