rebuld

Signed-off-by: ChenYunHey <[email protected]>
lakesoul-io · Apr 12, 2024 · d4a0e4e · d4a0e4e
1 parent 09e4410
commit d4a0e4e
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java
@@ -243,8 +243,6 @@ public static void xsyncToPg(StreamExecutionEnvironment env) throws SQLException
         Statement statement = conn.createStatement();
         // Create the target table in MySQL
         statement.executeUpdate(createTableSql.toString());
-//        String createCatalog = "create catalog postgres_catalog with('type'='jdbc','default-database'=" + "'" + targetDatabase + "'" + "," + "'username'=" +
-//                "'" + username + "'" + "," + "'password'=" + "'" + password + "'" + "," + "'base-url'=" + "'" + url + "'" + ")";
         StringBuilder coulmns = new StringBuilder();
         for (int i = 0; i < fieldTypes.length; i++) {
             if (stringFieldsTypes[i].equals("BYTEA")) {