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 03158295a7..2ad86977c8 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 class LogicalPlanBuilder extends DorisParserBaseVisitor { 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 class LogicalPlanBuilder extends DorisParserBaseVisitor { engineName, keysType, ctx.keys != null ? visitIdentifierList(ctx.keys) : ImmutableList.of(), - "", + comment, isAutoPartition, autoPartitionExpr.build(), partitionType, @@ -2495,7 +2497,7 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor { engineName, keysType, ctx.keys != null ? visitIdentifierList(ctx.keys) : ImmutableList.of(), - "", + comment, isAutoPartition, autoPartitionExpr.build(), partitionType,