diff --git a/src/chunked/arrow_converter.rs b/src/chunked/arrow_converter.rs index dd341ac..47f00bb 100644 --- a/src/chunked/arrow_converter.rs +++ b/src/chunked/arrow_converter.rs @@ -256,7 +256,6 @@ impl<'a> Converter<'a> for Slice2Arrow<'a> { match message { Ok(rb) => { - break 'outer; writer.write(&rb.record_batch).expect("Error Writing batch"); if (rb.record_batch.num_rows() == 0) { break 'outer;