Skip to content

Commit 32f0df2

Browse files
TyrantLuciferzhangchaoming.zcm
authored andcommitted
[polish] Add type parameter for MySqlRecords(apache#2300)
1 parent ca435fc commit 32f0df2

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)