[hotfix] update dbz option name 'xx. whitelist' to 'xx.include.list'(…

…xx = database, schema or table) (apache#2212) (cherry picked from commit ba5fcbc)
zhongqishang · Dec 7, 2023 · 130c427 · 130c427
1 parent a059c6d
commit 130c427
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/flink-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/Db2Source.java b/flink-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/Db2Source.java
@@ -63,7 +63,7 @@ public DebeziumSourceFunction<T> build() {
             props.setProperty("database.history.skip.unparseable.ddl", String.valueOf(true));
 
             if (tableList != null) {
-                props.setProperty("table.whitelist", String.join(",", tableList));
+                props.setProperty("table.include.list", String.join(",", tableList));
             }
             if (dbzProperties != null) {
                 props.putAll(dbzProperties);

diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java
@@ -180,10 +180,10 @@ public DebeziumSourceFunction<T> build() {
                 props.setProperty("database.server.id", String.valueOf(serverId));
             }
             if (databaseList != null) {
-                props.setProperty("database.whitelist", String.join(",", databaseList));
+                props.setProperty("database.include.list", String.join(",", databaseList));
             }
             if (tableList != null) {
-                props.setProperty("table.whitelist", String.join(",", tableList));
+                props.setProperty("table.include.list", String.join(",", tableList));
             }
             if (serverTimeZone != null) {
                 props.setProperty("database.serverTimezone", serverTimeZone);

diff --git a/...-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java b/...-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java
@@ -160,7 +160,7 @@ public DebeziumSourceFunction<T> build() {
             props.setProperty("database.history.skip.unparseable.ddl", String.valueOf(true));
             props.setProperty("database.dbname", checkNotNull(database));
             if (schemaList != null) {
-                props.setProperty("schema.whitelist", String.join(",", schemaList));
+                props.setProperty("schema.include.list", String.join(",", schemaList));
             }
             if (tableList != null) {
                 props.setProperty("table.include.list", String.join(",", tableList));

diff --git a/...ain/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java b/...ain/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java
@@ -94,7 +94,7 @@ public OracleSourceConfig create(int subtaskId) {
         }
 
         if (schemaList != null) {
-            props.setProperty("schema.whitelist", String.join(",", schemaList));
+            props.setProperty("schema.include.list", String.join(",", schemaList));
         }
 
         if (tableList != null) {

diff --git a/...or-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java b/...or-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java
@@ -166,10 +166,10 @@ public DebeziumSourceFunction<T> build() {
             props.setProperty("heartbeat.interval.ms", String.valueOf(DEFAULT_HEARTBEAT_MS));
 
             if (schemaList != null) {
-                props.setProperty("schema.whitelist", String.join(",", schemaList));
+                props.setProperty("schema.include.list", String.join(",", schemaList));
             }
             if (tableList != null) {
-                props.setProperty("table.whitelist", String.join(",", tableList));
+                props.setProperty("table.include.list", String.join(",", tableList));
             }
 
             if (dbzProperties != null) {