[FLINK] fix SyncDatabase bug (#553)

Signed-off-by: ChenYunHey <1908166778@qq.com>
lakesoul-io · Oct 25, 2024 · d233ac0 · d233ac0
1 parent bb19636
commit d233ac0
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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]);