From 583aed6c00669fa34945f7f9f74a249d93d70b51 Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh <viirya@gmail.com> Date: Fri, 1 Nov 2024 17:26:08 -0700 Subject: [PATCH] For review --- native/core/src/parquet/mod.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/native/core/src/parquet/mod.rs b/native/core/src/parquet/mod.rs index 46b97cb0b..455f19929 100644 --- a/native/core/src/parquet/mod.rs +++ b/native/core/src/parquet/mod.rs @@ -544,9 +544,8 @@ 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()) }) }