For review

viirya · Nov 2, 2024 · 583aed6 · 583aed6
1 parent 94ef085
commit 583aed6
Showing 1 changed file with 2 additions and 3 deletions.
diff --git 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())
     })
 }