Skip to content

Commit dd0e6db

Browse files
committed
fix bug for lost auto create off option for mysql mode
1 parent 7213958 commit dd0e6db

2 files changed

Lines changed: 8 additions & 8 deletions

File tree

  • tis-incr

tis-incr/tis-flink-cdc-postgresql-plugin/src/main/java/com/qlangtech/plugins/incr/flink/cdc/postgresql/PostgreSQLCDCValidator.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
/**
3434
* PostgreSQL CDC 先验校验工具类
3535
* 在Flink CDC任务启动前检查PostgreSQL数据源是否满足CDC运行条件
36-
*
36+
* see requirment/add-validator-before-pg-cdc-launching.md
3737
* @author: 百岁(baisui@qlangtech.com)
3838
* @create: 2025-01-19 20:00
3939
**/
@@ -80,12 +80,12 @@ public static ValidationResult validate(Connection conn,
8080
// 6. 检查解码插件配置
8181
validateDecodingPlugin(conn, sourceFactory, result);
8282

83-
// 7. 检查监听表结构
84-
if (selectedTables != null && !selectedTables.isEmpty()) {
85-
for (String tableName : selectedTables) {
86-
validateTableStructure(conn, tableName, result);
87-
}
88-
}
83+
// 7. 检查监听表结构, 表存在先不监听
84+
// if (selectedTables != null && !selectedTables.isEmpty()) {
85+
// for (String tableName : selectedTables) {
86+
// validateTableStructure(conn, tableName, result);
87+
// }
88+
// }
8989

9090
} catch (SQLException e) {
9191
logger.error("Database error occurred during PostgreSQL CDC validation", e);
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
{
22
"autoCreateTable": {
3-
"subDescEnumFilter": "return com.qlangtech.tis.plugin.datax.common.AutoCreateTable.descFilter(desc,\"kingbase\",\"mysql\");"
3+
"subDescEnumFilter": "return com.qlangtech.tis.plugin.datax.common.AutoCreateTable.descFilter(desc,\"mysql\");"
44
}
55
}

0 commit comments

Comments
 (0)