This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 0bc26d8191 [INLONG-8897][Sort] update dbz option name 'xx. whitelist'
to 'xx.include.list'(xx = database, schema or table) (#8898)
0bc26d8191 is described below
commit 0bc26d819119b34350fd44eefc6ab98e6484c475
Author: e-mhui <[email protected]>
AuthorDate: Tue Sep 12 16:56:11 2023 +0800
[INLONG-8897][Sort] update dbz option name 'xx. whitelist' to
'xx.include.list'(xx = database, schema or table) (#8898)
---
.../src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java | 4 ++--
.../java/org/apache/inlong/sort/cdc/mysql/debezium/DebeziumUtils.java | 2 +-
.../src/main/java/org/apache/inlong/sort/cdc/oracle/OracleSource.java | 2 +-
.../sort/cdc/oracle/source/config/OracleSourceConfigFactory.java | 2 +-
.../java/org/apache/inlong/sort/cdc/postgres/PostgreSQLSource.java | 4 ++--
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java
index be82ae13c3..cce9d021f4 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java
@@ -219,10 +219,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/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/DebeziumUtils.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/DebeziumUtils.java
index 547018f07e..ea1806d8e5 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/DebeziumUtils.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/DebeziumUtils.java
@@ -230,7 +230,7 @@ public class DebeziumUtils {
/**
* Creates {@link RelationalTableFilters} from configuration. The {@link
RelationalTableFilters}
- * can be used to filter tables according to "table.whitelist" and
"database.whitelist" options.
+ * can be used to filter tables according to "table.include.list" and
"database.include.list" options.
*/
public static RelationalTableFilters createTableFilters(MySqlSourceConfig
configuration) {
Configuration debeziumConfig = configuration.getDbzConfiguration();
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/OracleSource.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/OracleSource.java
index 31da881855..c17c492e4c 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/OracleSource.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/OracleSource.java
@@ -165,7 +165,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/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/config/OracleSourceConfigFactory.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/config/OracleSourceConfigFactory.java
index 794a577d72..066a768648 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/config/OracleSourceConfigFactory.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/config/OracleSourceConfigFactory.java
@@ -109,7 +109,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/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/PostgreSQLSource.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/PostgreSQLSource.java
index 166ca773f2..9b251ae026 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/PostgreSQLSource.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/PostgreSQLSource.java
@@ -185,10 +185,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) {
