diff --git a/datafusion-cli/src/print_options.rs b/datafusion-cli/src/print_options.rs index b8594352b585..b382eb34f62c 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,