diff --git a/native/core/src/parquet/mod.rs b/native/core/src/parquet/mod.rs index 46b97cb0b5..0773901fa5 100644 --- a/native/core/src/parquet/mod.rs +++ b/native/core/src/parquet/mod.rs @@ -544,9 +544,7 @@ pub extern "system" fn Java_org_apache_comet_parquet_Native_currentBatch( let ctx = get_context(handle)?; let reader = &mut ctx.column_reader; let data = reader.current_batch(); - data.move_to_spark(array_addr, schema_addr)?; - - Ok(()) + data.move_to_spark(array_addr, schema_addr).map_err(|e| e.into()) }) }