diff --git a/connectorx-python/src/arrow2.rs b/connectorx-python/src/arrow2.rs index 271292527..ac9acb1fd 100644 --- a/connectorx-python/src/arrow2.rs +++ b/connectorx-python/src/arrow2.rs @@ -1,6 +1,6 @@ use crate::errors::ConnectorXPythonError; use arrow2::{ - array::ArrayRef, + array::Array, chunk::Chunk, datatypes::{Field, Schema}, ffi, @@ -28,7 +28,7 @@ pub fn write_arrow<'a>( } fn to_ptrs( - rbs: Vec>, + rbs: Vec>>, schema: Arc, ) -> (Vec, Vec>) { if rbs.is_empty() { @@ -49,9 +49,8 @@ fn to_ptrs( unsafe { ffi::export_field_to_c( &Field::new("", array.data_type().clone(), true), - schema_ptr, ); - ffi::export_array_to_c(array.clone(), array_ptr); + ffi::export_array_to_c(array.clone()); }; cols.push((array_ptr as uintptr_t, schema_ptr as uintptr_t)); }