From d1b61a9d5e9d10e8efd65bc46265be37888b138a Mon Sep 17 00:00:00 2001 From: congyi <15605187270@163.com> Date: Thu, 14 Mar 2024 17:11:07 +0800 Subject: [PATCH] fix typo --- src/connector/src/sink/opendal_sink/mod.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/connector/src/sink/opendal_sink/mod.rs b/src/connector/src/sink/opendal_sink/mod.rs index 8415d9de84c70..723450cce1645 100644 --- a/src/connector/src/sink/opendal_sink/mod.rs +++ b/src/connector/src/sink/opendal_sink/mod.rs @@ -152,16 +152,16 @@ fn convert_rw_schema_to_arrow_schema( // This assert is to make sure there is no duplicate field name in the schema. assert!(res.is_none()) }); - let mut arrow_fileds = vec![]; + let mut arrow_fields = vec![]; for rw_field in &rw_schema.fields { let converted_arrow_data_type = ArrowDataType::try_from(rw_field.data_type.clone()).map_err(|e| anyhow!(e))?; - arrow_fileds.push(ArrowField::new( + arrow_fields.push(ArrowField::new( rw_field.name.clone(), converted_arrow_data_type, false, )); } - Ok(arrow_schema::Schema::new(arrow_fileds)) + Ok(arrow_schema::Schema::new(arrow_fields)) }