Skip to content

Commit 6206647

Browse files
committed
[FLINK-38218] Eliminate code duplication in MySqlBinlogSplit constructors
1 parent 821e327 commit 6206647

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -74,14 +74,14 @@ public MySqlBinlogSplit(
7474
List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos,
7575
Map<TableId, TableChange> tableSchemas,
7676
int totalFinishedSplitSize) {
77-
super(splitId);
78-
this.startingOffset = startingOffset;
79-
this.endingOffset = endingOffset;
80-
this.finishedSnapshotSplitInfos = finishedSnapshotSplitInfos;
81-
this.tableSchemas = tableSchemas;
82-
this.totalFinishedSplitSize = totalFinishedSplitSize;
83-
this.isSuspended = false;
84-
this.tablesForLog = getTablesForLog();
77+
this(
78+
splitId,
79+
startingOffset,
80+
endingOffset,
81+
finishedSnapshotSplitInfos,
82+
tableSchemas,
83+
totalFinishedSplitSize,
84+
false);
8585
}
8686

8787
public BinlogOffset getStartingOffset() {

0 commit comments

Comments
 (0)