From 1741c1a0313163f68978003b6dff7758d0ddc844 Mon Sep 17 00:00:00 2001 From: ChenYunHey <90120383+ChenYunHey@users.noreply.github.com> Date: Mon, 22 Jan 2024 15:46:48 +0800 Subject: [PATCH] [Flink] Fix CDC entry db name (#430) * fix postgresql entry bug Signed-off-by: ChenYunHey <1908166778@qq.com> * fix jdbcCDC entry Signed-off-by: ChenYunHey <1908166778@qq.com> --------- Signed-off-by: ChenYunHey <1908166778@qq.com> --- .../src/main/java/org/apache/flink/lakesoul/entry/JdbcCDC.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/JdbcCDC.java b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/JdbcCDC.java index 8369f4e9a..00c0471da 100644 --- a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/JdbcCDC.java +++ b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/JdbcCDC.java @@ -62,7 +62,7 @@ public static void main(String[] args) throws Exception { host = parameter.get(SOURCE_DB_HOST.key()); port = parameter.getInt(SOURCE_DB_PORT.key(), MysqlDBManager.DEFAULT_MYSQL_PORT); //Postgres Oracle - if (dbType.equals("orcale") || dbType.equalsIgnoreCase("postgresql")) { + if (dbType.equalsIgnoreCase("oracle") || dbType.equalsIgnoreCase("postgres")) { schemaList = parameter.get(SOURCE_DB_SCHEMA_LIST.key()).split(","); String[] tables = parameter.get(SOURCE_DB_SCHEMA_TABLES.key()).split(","); tableList = new String[tables.length];