From 130c427c10a4cacb59980e76010775437ecd67c9 Mon Sep 17 00:00:00 2001 From: BIN Date: Thu, 29 Jun 2023 17:00:25 +0800 Subject: [PATCH] [hotfix] update dbz option name 'xx. whitelist' to 'xx.include.list'(xx = database, schema or table) (#2212) (cherry picked from commit ba5fcbc97b46bbe57a2937622afa1562885beed8) --- .../main/java/com/ververica/cdc/connectors/db2/Db2Source.java | 2 +- .../java/com/ververica/cdc/connectors/mysql/MySqlSource.java | 4 ++-- .../com/ververica/cdc/connectors/oracle/OracleSource.java | 2 +- .../oracle/source/config/OracleSourceConfigFactory.java | 2 +- .../ververica/cdc/connectors/postgres/PostgreSQLSource.java | 4 ++-- 5 files changed, 7 insertions(+), 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 index 8b2fc3591a8..6788afadb58 100644 --- 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 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 index 4be8b93529a..233110d9e18 100644 --- 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 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/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java index de3fe9f6b40..81afad78758 100644 --- a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java +++ b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java @@ -160,7 +160,7 @@ public DebeziumSourceFunction 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/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java index bc986faf9d4..ff0ae36dad3 100644 --- a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java +++ b/flink-connector-oracle-cdc/src/main/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/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java b/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java index 188d1818a0c..21ee0219a3b 100644 --- a/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java +++ b/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java @@ -166,10 +166,10 @@ public DebeziumSourceFunction 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) {