This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 821db545be Error handling. (#8761)
821db545be is described below
commit 821db545be48b39d8522310bf08bc4b0bb28d4bf
Author: Metehan Yıldırım <[email protected]>
AuthorDate: Sat Jan 6 00:17:04 2024 +0300
Error handling. (#8761)
---
datafusion-cli/src/print_options.rs | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/datafusion-cli/src/print_options.rs
b/datafusion-cli/src/print_options.rs
index b8594352b5..b382eb34f6 100644
--- a/datafusion-cli/src/print_options.rs
+++ b/datafusion-cli/src/print_options.rs
@@ -141,7 +141,8 @@ impl PrintOptions {
let mut row_count = 0_usize;
let mut with_header = true;
- while let Some(Ok(batch)) = stream.next().await {
+ while let Some(maybe_batch) = stream.next().await {
+ let batch = maybe_batch?;
row_count += batch.num_rows();
self.format.print_batches(
&mut writer,
