diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java index ff8e07f5ed2d63..d1967d6d54dda1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java @@ -2414,6 +2414,8 @@ public LogicalPlan visitCreateTable(CreateTableContext ctx) { if (ctx.INTEGER_VALUE() != null) { bucketNum = Integer.parseInt(ctx.INTEGER_VALUE().getText()); } + String comment = ctx.STRING_LITERAL() == null ? "" : LogicalPlanBuilderAssistant.escapeBackSlash( + ctx.STRING_LITERAL().getText().substring(1, ctx.STRING_LITERAL().getText().length() - 1)); DistributionDescriptor desc = null; if (ctx.HASH() != null) { desc = new DistributionDescriptor(true, ctx.autoBucket != null, bucketNum, @@ -2473,7 +2475,7 @@ public LogicalPlan visitCreateTable(CreateTableContext ctx) { engineName, keysType, ctx.keys != null ? visitIdentifierList(ctx.keys) : ImmutableList.of(), - "", + comment, isAutoPartition, autoPartitionExpr.build(), partitionType, @@ -2495,7 +2497,7 @@ public LogicalPlan visitCreateTable(CreateTableContext ctx) { engineName, keysType, ctx.keys != null ? visitIdentifierList(ctx.keys) : ImmutableList.of(), - "", + comment, isAutoPartition, autoPartitionExpr.build(), partitionType,