From 6d40b4b89a0243539fc5ef124aebbd586779b102 Mon Sep 17 00:00:00 2001 From: Bugen Zhao Date: Fri, 14 Feb 2025 14:09:22 +0800 Subject: [PATCH] fmt Signed-off-by: Bugen Zhao --- src/connector/src/sink/deltalake.rs | 2 -- src/connector/src/sink/kafka.rs | 2 -- src/connector/src/sink/postgres.rs | 4 ---- src/connector/src/sink/redis.rs | 4 ---- src/frontend/src/optimizer/plan_node/generic/agg.rs | 1 - src/frontend/src/optimizer/plan_node/generic/now.rs | 1 - src/frontend/src/optimizer/plan_node/generic/source.rs | 2 -- src/frontend/src/optimizer/plan_node/logical_source.rs | 3 --- src/frontend/src/optimizer/plan_node/stream_source_scan.rs | 2 -- .../src/optimizer/plan_node/stream_watermark_filter.rs | 2 -- 10 files changed, 23 deletions(-) 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 371b0870255f4..2ab2b9e2f9c1d 100644 --- a/src/connector/src/sink/redis.rs +++ b/src/connector/src/sink/redis.rs @@ -507,12 +507,10 @@ mod test { Field { data_type: DataType::Int32, name: "id".to_owned(), - }, Field { data_type: DataType::Varchar, name: "name".to_owned(), - }, ]); @@ -578,12 +576,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 Agg { 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);