Skip to content

Commit 829904a

Browse files
committed
fix code style
1 parent da491c8 commit 829904a

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,8 @@ private boolean hasEnterPureBinlogPhase(TableId tableId, BinlogOffset position)
323323
}
324324
}
325325

326-
// Case 3: Use still need to capture new sharding table if user disable scan new added table,
326+
// Case 3: Use still need to capture new sharding table if user disable scan new added
327+
// table,
327328
// The history records for all new added tables(including sharding table and normal table)
328329
// will be capture after restore from a savepoint if user enable scan new added table
329330
if (!statefulTaskContext.getSourceConfig().isScanNewlyAddedTableEnabled()) {

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,6 @@ public MySqlSourceBuilder<T> scanBinlogNewlyAddedTableEnabled(
224224
return this;
225225
}
226226

227-
228227
/** Specifies the startup options. */
229228
public MySqlSourceBuilder<T> startupOptions(StartupOptions startupOptions) {
230229
this.configFactory.startupOptions(startupOptions);

0 commit comments

Comments
 (0)