github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[hotfix] update dbz option name 'xx. whitelist' to 'xx.include.list'(xx = database, schema or table) (#2212)

Browse Source
pull/2255/head
BIN 2 years ago committed by GitHub
parent 70250a7187
commit ba5fcbc97b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File

2
flink-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/Db2Source.java
Unescape Escape View File

@ -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);

4
flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java
Unescape Escape View File

@ -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);

2
flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleSource.java
Unescape Escape View File

@ -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));

2
flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java
Unescape Escape View File

@ -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) {

4
flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/PostgreSQLSource.java
Unescape Escape View File

@ -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) {

Write Preview
Loading…
Cancel
Save