Refactored sink creation & updated DDL field init

src/frontend/src/handler/create_sink.rs

@@ -698,10 +698,8 @@ pub(crate) fn insert_merger_to_union_with_project(
                 })),
                 ..Default::default()
             }],
-            stream_key: vec![],
-            append_only: false,
             identity: uniq_name.to_string(),
-            fields: vec![],
+            fields: node.fields.clone(),
             node_body: Some(project_node.clone()),
             ..Default::default()
         });

src/meta/src/rpc/ddl_controller.rs

@@ -1279,8 +1279,6 @@ impl DdlController {
 
                                     merge_stream_node.fields = sink_fields.to_vec();
 
-                                    input_project_node.fields.clone_from(&node.fields);
-
                                     return false;
                                 }
                             }