[fix](nereids)fix bug of lost rollup property in create table stateme…

…nt (apache#25580)
HappenLee · Oct 20, 2023 · 2cd22e5 · 2cd22e5
1 parent 26f8c7e
commit 2cd22e5
Showing 1 changed file with 3 additions and 3 deletions.
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
@@ -1918,7 +1918,7 @@ public LogicalPlan visitCreateTable(CreateTableContext ctx) {
                     ctx.partitionKeys != null ? visitIdentifierList(ctx.partitionKeys) : null,
                     ctx.partitions != null ? visitPartitionsDef(ctx.partitions) : null,
                     desc,
-                    ImmutableList.of(),
+                    ctx.rollupDefs() != null ? visitRollupDefs(ctx.rollupDefs()) : ImmutableList.of(),
                     properties));
         } else if (ctx.AS() != null) {
             return new CreateTableCommand(Optional.of(visitQuery(ctx.query())), new CreateTableInfo(
@@ -1934,7 +1934,7 @@ public LogicalPlan visitCreateTable(CreateTableContext ctx) {
                     ctx.partitionKeys != null ? visitIdentifierList(ctx.partitionKeys) : null,
                     ctx.partitions != null ? visitPartitionsDef(ctx.partitions) : null,
                     desc,
-                    ImmutableList.of(),
+                    ctx.rollupDefs() != null ? visitRollupDefs(ctx.rollupDefs()) : ImmutableList.of(),
                     properties));
         } else {
             throw new AnalysisException("Should contain at least one column in a table");
@@ -2067,7 +2067,7 @@ public Expression visitPartitionValueDef(PartitionValueDefContext ctx) {
     }
 
     @Override
-    public Object visitRollupDefs(RollupDefsContext ctx) {
+    public List<RollupDefinition> visitRollupDefs(RollupDefsContext ctx) {
         return ctx.rollups.stream().map(this::visitRollupDef).collect(Collectors.toList());
     }