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 8b2fc3591..6788afadb 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 class Db2Source { 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 4be8b9352..233110d9e 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 class MySqlSource { 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 de3fe9f6b..81afad787 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 class OracleSource { 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 bc986faf9..ff0ae36da 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 class OracleSourceConfigFactory extends JdbcSourceConfigFactory { } 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 188d1818a..21ee0219a 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 class PostgreSQLSource { 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) {