Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
wcy-fdu committed Mar 14, 2024
1 parent 31a8052 commit d1b61a9
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/connector/src/sink/opendal_sink/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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))
}

0 comments on commit d1b61a9

Please sign in to comment.