Skip to content

Commit 7bb5253

Browse files
TyrantLuciferleonardBang
authored andcommitted
[polish] Add type parameter for MySqlRecords(#2300)
(cherry picked from commit bca60a4)
1 parent 0026ddd commit 7bb5253

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/split/MySqlRecords.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public final class MySqlRecords implements RecordsWithSplitIds<SourceRecords> {
3636

3737
public MySqlRecords(
3838
@Nullable String splitId,
39-
@Nullable Iterator recordsForSplit,
39+
@Nullable Iterator<SourceRecords> recordsForSplit,
4040
Set<String> finishedSnapshotSplits) {
4141
this.splitId = splitId;
4242
this.recordsForSplit = recordsForSplit;

0 commit comments

Comments
 (0)