From b5bf610838c2d48d55357711e64882c125c0277b Mon Sep 17 00:00:00 2001 From: discord9 Date: Wed, 18 Dec 2024 19:39:37 +0800 Subject: [PATCH] chore: clippy --- src/flow/src/adapter/flownode_impl.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/flow/src/adapter/flownode_impl.rs b/src/flow/src/adapter/flownode_impl.rs index 57c6513359c7..ce72d7a35af3 100644 --- a/src/flow/src/adapter/flownode_impl.rs +++ b/src/flow/src/adapter/flownode_impl.rs @@ -209,7 +209,7 @@ impl Flownode for FlowWorkerManager { .collect_vec(); let batch_datatypes = insert_schema .iter() - .map(|s| from_proto_to_column_schema(s)) + .map(from_proto_to_column_schema) .collect::, _>>() .map_err(to_meta_err)?; self.handle_write_request(region_id.into(), rows, &batch_datatypes)