diff --git a/connectors/starrocks-connector/src/main/java/io/tapdata/connector/starrocks/StarrocksSqlMaker.java b/connectors/starrocks-connector/src/main/java/io/tapdata/connector/starrocks/StarrocksSqlMaker.java index 3c03ed7bd..200e3616e 100644 --- a/connectors/starrocks-connector/src/main/java/io/tapdata/connector/starrocks/StarrocksSqlMaker.java +++ b/connectors/starrocks-connector/src/main/java/io/tapdata/connector/starrocks/StarrocksSqlMaker.java @@ -31,7 +31,9 @@ public String buildColumnDefinitionByOrder(TapTable tapTable, Collection builder.append("REPLACE_IF_NOT_NULL "); } buildNullDefinition(builder, tapField); - buildDefaultDefinition(builder, tapField); + if (Boolean.TRUE.equals(applyDefault)) { + buildDefaultDefinition(builder, tapField); + } buildCommentDefinition(builder, tapField); return builder.toString(); }).collect(Collectors.joining(", "));