From 991851bc60e434899f80078d06077fd11f8a24be Mon Sep 17 00:00:00 2001
From: tyrantlucifer <tyrantlucifer@gmail.com>
Date: Thu, 13 Jul 2023 20:33:11 +0800
Subject: [PATCH] [mysql] add the definite type for MySqlRecords's param

---
 .../cdc/connectors/mysql/source/split/MySqlRecords.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;