From e0095458a1847230ce9bdd1e7b4c178ce3ad895d Mon Sep 17 00:00:00 2001
From: Leonard Xu <xbjtdcq@gmail.com>
Date: Wed, 3 Nov 2021 17:30:07 +0800
Subject: [PATCH] [mysql][minor] Use 'table.include.list' key instead of legacy
 key 'table.whitelist' in SnapshotSplitReader

---
 .../connectors/mysql/debezium/reader/SnapshotSplitReader.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 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
index dd2d47c61..8c893182e 100644
--- 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(