[polish] Add type parameter for MySqlRecords(#2300)

apache · Jul 25, 2023 · bca60a4 · bca60a4
1 parent 6c2fe08
commit bca60a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java b/...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;