fix

apache · Dec 5, 2024 · 9e9dfe1 · 9e9dfe1
1 parent 07561a4
commit 9e9dfe1
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/...ain/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java b/...ain/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
@@ -43,7 +43,9 @@
 import org.apache.doris.nereids.rules.analysis.BindSink;
 import org.apache.doris.nereids.rules.implementation.LogicalOlapTableSinkToPhysicalOlapTableSink;
 import org.apache.doris.nereids.rules.rewrite.MergeProjects;
+import org.apache.doris.nereids.trees.expressions.NamedExpression;
 import org.apache.doris.nereids.trees.expressions.Slot;
+import org.apache.doris.nereids.trees.expressions.SlotReference;
 import org.apache.doris.nereids.trees.plans.Explainable;
 import org.apache.doris.nereids.trees.plans.Plan;
 import org.apache.doris.nereids.trees.plans.PlanType;
@@ -496,10 +498,15 @@ public Plan visitUnboundTableSink(
                 public Plan visitLogicalInlineTable(LogicalInlineTable logicalInlineTable, Void context) {
                     logicalInlineTable =
                             (LogicalInlineTable) super.visitLogicalInlineTable(logicalInlineTable, context);
+
+                    List<NamedExpression> outputs = Lists.newArrayList();
+                    for (Slot slot : logicalInlineTable.getOutput()) {
+                        outputs.add(new SlotReference(slot.getName(), slot.getDataType(), slot.nullable()));
+                    }
+
                     return new LogicalUnion(
-                            Qualifier.ALL, logicalInlineTable.getConstantExprsList().get(0),
-                            ImmutableList.of(), logicalInlineTable.getConstantExprsList(), false, ImmutableList.of()
-                    );
+                            Qualifier.ALL, logicalInlineTable.getConstantExprsList(), ImmutableList.of()
+                    ).withNewOutputs(outputs);
                 }
             };