[Flink] Fix CDC entry db name (#430)

* fix postgresql entry bug Signed-off-by: ChenYunHey <[email protected]> * fix jdbcCDC entry Signed-off-by: ChenYunHey <[email protected]> --------- Signed-off-by: ChenYunHey <[email protected]>
lakesoul-io · Jan 22, 2024 · 1741c1a · 1741c1a
1 parent fe5ca72
commit 1741c1a
Showing 1 changed file with 1 addition and 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
@@ -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];