[mysql][minor] Use 'table.include.list' key instead of legacy key 'table.whitelist' in SnapshotSplitReader

3 years ago · e0095458a1
parent aa3e282cfd
commit e0095458a1
1 changed files with 1 additions and 1 deletions
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java
@ -179,7 +179,7 @@ public class SnapshotSplitReader implements DebeziumReader<SourceRecord, MySqlSp
                        .getSourceConfig()
                        .getDbzConfiguration()
                        .edit()
-                        .with("table.whitelist", currentSnapshotSplit.getTableId())
+                        .with("table.include.list", currentSnapshotSplit.getTableId().toString())
                        .build();
        // task to read binlog and backfill for current split
        return new MySqlBinlogSplitReadTask(