From 0c7663a942a9c91fc46947331c974a18c62a8519 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Wed, 11 Sep 2024 14:37:16 +0800 Subject: [PATCH] update --- .../apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java | 4 ++-- .../doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java | 4 ++-- .../doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java | 4 ++-- .../doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java | 4 ++-- .../doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java | 4 ++-- .../doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java | 4 ++-- 6 files changed, 12 insertions(+), 12 deletions(-) diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java index 0666cb9d4..055365570 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java @@ -65,8 +65,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); String includingTables = "FULL_TYPES"; String excludingTables = null; String multiToOneOrigin = null; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java index 09006b2cb..ffc8a75d8 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java @@ -68,8 +68,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, ".*:1"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, ".*:1"); String includingTables = "cdc_test"; String excludingTables = ""; String multiToOneOrigin = "a_.*|b_.*"; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java index c430ea87b..e85e888fc 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java @@ -67,8 +67,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); // String includingTables = "tbl1|tbl2|tbl3"; String includingTables = "a_.*|b_.*|c"; String excludingTables = ""; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java index a47212c8e..92600ffd6 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java @@ -62,8 +62,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); String includingTables = "a_.*|b_.*|c"; String excludingTables = ""; String multiToOneOrigin = "a_.*|b_.*"; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java index 99892e022..331840117 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java @@ -66,8 +66,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); String includingTables = "a_.*|b_.*|c"; String excludingTables = ""; String multiToOneOrigin = "a_.*|b_.*"; diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java index ca6a3121b..7a1cf276a 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java @@ -65,8 +65,8 @@ public static void main(String[] args) throws Exception { Configuration sinkConf = Configuration.fromMap(sinkConfig); Map tableConfig = new HashMap<>(); - tableConfig.put(DatabaseSyncConfig.REPLICATION_NUM, "1"); - tableConfig.put(DatabaseSyncConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); + tableConfig.put(DorisTableConfig.REPLICATION_NUM, "1"); + tableConfig.put(DorisTableConfig.TABLE_BUCKETS, "tbl1:10,tbl2:20,a.*:30,b.*:40,.*:50"); String includingTables = "a_.*|b_.*|c"; String excludingTables = ""; String multiToOneOrigin = "a_.*|b_.*";