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 index cf9c44feb..9337048c3 100644 --- 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 @@ -285,7 +285,7 @@ public static void xsyncToPg(StreamExecutionEnvironment env) throws SQLException coulmns.append("`").append(fieldNames[i]).append("` ").append("VARCHAR"); break; case "FLOAT8": - coulmns.append("`").append(fieldNames[i]).append("`").append("DOUBLE"); + coulmns.append("`").append(fieldNames[i]).append("` ").append("DOUBLE"); break; default: coulmns.append("`").append(fieldNames[i]).append("` ").append(stringFieldsTypes[i]);