fix(frontend): fix dml output fields (#12881) (#12884)

Co-authored-by: Dylan <[email protected]>
risingwavelabs · Oct 16, 2023 · cab8135 · cab8135
1 parent 69ab415
commit cab8135
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/src/frontend/src/binder/statement.rs b/src/frontend/src/binder/statement.rs
@@ -32,18 +32,18 @@ pub enum BoundStatement {
 impl BoundStatement {
     pub fn output_fields(&self) -> Vec<Field> {
         match self {
-            BoundStatement::Insert(i) => i.returning_schema.as_ref().map_or(
-                vec![Field::unnamed(risingwave_common::types::DataType::Int64)],
-                |s| s.fields().into(),
-            ),
-            BoundStatement::Delete(d) => d.returning_schema.as_ref().map_or(
-                vec![Field::unnamed(risingwave_common::types::DataType::Int64)],
-                |s| s.fields().into(),
-            ),
-            BoundStatement::Update(u) => u.returning_schema.as_ref().map_or(
-                vec![Field::unnamed(risingwave_common::types::DataType::Int64)],
-                |s| s.fields().into(),
-            ),
+            BoundStatement::Insert(i) => i
+                .returning_schema
+                .as_ref()
+                .map_or(vec![], |s| s.fields().into()),
+            BoundStatement::Delete(d) => d
+                .returning_schema
+                .as_ref()
+                .map_or(vec![], |s| s.fields().into()),
+            BoundStatement::Update(u) => u
+                .returning_schema
+                .as_ref()
+                .map_or(vec![], |s| s.fields().into()),
             BoundStatement::Query(q) => q.schema().fields().into(),
         }
     }