diff --git a/chunjun-connectors/chunjun-connector-kingbase/src/main/java/com/dtstack/chunjun/connector/kingbase/dialect/KingbaseDialect.java b/chunjun-connectors/chunjun-connector-kingbase/src/main/java/com/dtstack/chunjun/connector/kingbase/dialect/KingbaseDialect.java index 3fe535dfe8..d0fed0c6a8 100644 --- a/chunjun-connectors/chunjun-connector-kingbase/src/main/java/com/dtstack/chunjun/connector/kingbase/dialect/KingbaseDialect.java +++ b/chunjun-connectors/chunjun-connector-kingbase/src/main/java/com/dtstack/chunjun/connector/kingbase/dialect/KingbaseDialect.java @@ -118,7 +118,7 @@ public String getInsertIntoStatement(String schema, String tableName, String[] f Arrays.stream(fieldNames).map(f -> ":" + f).collect(Collectors.joining(", ")); return "INSERT INTO " + buildTableInfoWithSchema(schema, tableName) - + " t1 " + + " as t1 " + "(" + columns + ")"