diff --git a/src/connector/src/sink/deltalake.rs b/src/connector/src/sink/deltalake.rs
index 57ebb1e5815bb..d284ab41f3390 100644
--- a/src/connector/src/sink/deltalake.rs
+++ b/src/connector/src/sink/deltalake.rs
@@ -616,12 +616,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".into(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".into(),
-
             },
         ]);
 
diff --git a/src/connector/src/sink/kafka.rs b/src/connector/src/sink/kafka.rs
index bdfd41bfa563d..50e92c88b94bc 100644
--- a/src/connector/src/sink/kafka.rs
+++ b/src/connector/src/sink/kafka.rs
@@ -752,12 +752,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".into(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "v2".into(),
-
             },
         ]);
 
diff --git a/src/connector/src/sink/postgres.rs b/src/connector/src/sink/postgres.rs
index 71239e0291c1a..122d4490f057c 100644
--- a/src/connector/src/sink/postgres.rs
+++ b/src/connector/src/sink/postgres.rs
@@ -602,12 +602,10 @@ mod tests {
             Field {
                 data_type: DataType::Int32,
                 name: "a".to_owned(),
-
             },
             Field {
                 data_type: DataType::Int32,
                 name: "b".to_owned(),
-
             },
         ]);
         let table_name = "test_table";
@@ -624,12 +622,10 @@ mod tests {
             Field {
                 data_type: DataType::Int32,
                 name: "a".to_owned(),
-
             },
             Field {
                 data_type: DataType::Int32,
                 name: "b".to_owned(),
-
             },
         ]);
         let table_name = "test_table";
diff --git a/src/connector/src/sink/redis.rs b/src/connector/src/sink/redis.rs
index 9e18b85fbb590..d5303a82b7822 100644
--- a/src/connector/src/sink/redis.rs
+++ b/src/connector/src/sink/redis.rs
@@ -508,12 +508,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".to_owned(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".to_owned(),
-
             },
         ]);
 
@@ -579,12 +577,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".to_owned(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".to_owned(),
-
             },
         ]);
 
diff --git a/src/frontend/src/optimizer/plan_node/generic/agg.rs b/src/frontend/src/optimizer/plan_node/generic/agg.rs
index 4f8ddbf864471..6afdf6ed795a8 100644
--- a/src/frontend/src/optimizer/plan_node/generic/agg.rs
+++ b/src/frontend/src/optimizer/plan_node/generic/agg.rs
@@ -676,7 +676,6 @@ impl<PlanRef: stream::StreamPlanRef> Agg<PlanRef> {
                     table_builder.add_column(&Field {
                         data_type: DataType::Int64,
                         name: format!("count_for_agg_call_{}", call_index),
-
                     });
                 }
                 table_builder
diff --git a/src/frontend/src/optimizer/plan_node/generic/now.rs b/src/frontend/src/optimizer/plan_node/generic/now.rs
index 6422b5bd80834..094ce49e0c39b 100644
--- a/src/frontend/src/optimizer/plan_node/generic/now.rs
+++ b/src/frontend/src/optimizer/plan_node/generic/now.rs
@@ -58,7 +58,6 @@ impl GenericPlanNode for Now {
             } else {
                 "ts"
             }),
-
         }])
     }
 
diff --git a/src/frontend/src/optimizer/plan_node/generic/source.rs b/src/frontend/src/optimizer/plan_node/generic/source.rs
index 741224097ef0a..5a4c182031485 100644
--- a/src/frontend/src/optimizer/plan_node/generic/source.rs
+++ b/src/frontend/src/optimizer/plan_node/generic/source.rs
@@ -163,12 +163,10 @@ impl Source {
         let key = Field {
             data_type: DataType::Varchar,
             name: "partition_id".to_owned(),
-
         };
         let value = Field {
             data_type: DataType::Jsonb,
             name: "offset_info".to_owned(),
-
         };
 
         let ordered_col_idx = builder.add_column(&key);
diff --git a/src/frontend/src/optimizer/plan_node/logical_source.rs b/src/frontend/src/optimizer/plan_node/logical_source.rs
index 692abb5464b57..179b90fd0de62 100644
--- a/src/frontend/src/optimizer/plan_node/logical_source.rs
+++ b/src/frontend/src/optimizer/plan_node/logical_source.rs
@@ -188,7 +188,6 @@ impl LogicalSource {
                         &Field {
                             name: "filename".to_owned(),
                             data_type: DataType::Varchar,
-
                         },
                         0,
                     ),
@@ -199,7 +198,6 @@ impl LogicalSource {
                         &Field {
                             name: "last_edit_time".to_owned(),
                             data_type: DataType::Timestamptz,
-
                         },
                         1,
                     ),
@@ -210,7 +208,6 @@ impl LogicalSource {
                         &Field {
                             name: "file_size".to_owned(),
                             data_type: DataType::Int64,
-
                         },
                         0,
                     ),
diff --git a/src/frontend/src/optimizer/plan_node/stream_source_scan.rs b/src/frontend/src/optimizer/plan_node/stream_source_scan.rs
index 98ac9814aca70..ea2b7aeb18181 100644
--- a/src/frontend/src/optimizer/plan_node/stream_source_scan.rs
+++ b/src/frontend/src/optimizer/plan_node/stream_source_scan.rs
@@ -85,12 +85,10 @@ impl StreamSourceScan {
         let key = Field {
             data_type: DataType::Varchar,
             name: "partition_id".to_owned(),
-
         };
         let value = Field {
             data_type: DataType::Jsonb,
             name: "backfill_progress".to_owned(),
-
         };
 
         let ordered_col_idx = builder.add_column(&key);
diff --git a/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs b/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs
index a091205c37936..cdde85dcd1da5 100644
--- a/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs
+++ b/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs
@@ -122,12 +122,10 @@ pub fn infer_internal_table_catalog(watermark_type: DataType) -> TableCatalog {
     let key = Field {
         data_type: DataType::Int16,
         name: "vnode".to_owned(),
-
     };
     let value = Field {
         data_type: watermark_type,
         name: "offset".to_owned(),
-
     };
 
     let ordered_col_idx = builder.add_column(&key);