You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by tu...@apache.org on 2023/01/20 14:36:31 UTC

[arrow-rs] branch master updated: Correct error return (#3576)

This is an automated email from the ASF dual-hosted git repository.

tustvold pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git


The following commit(s) were added to refs/heads/master by this push:
     new a1cedb4fd Correct error return (#3576)
a1cedb4fd is described below

commit a1cedb4fdfb561eda4e836a6c8fcb898d7a37029
Author: sachin agarwal <as...@gmail.com>
AuthorDate: Fri Jan 20 20:06:25 2023 +0530

    Correct error return (#3576)
---
 parquet/src/arrow/async_reader/mod.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/parquet/src/arrow/async_reader/mod.rs b/parquet/src/arrow/async_reader/mod.rs
index 64b334fd4..780ba6f3b 100644
--- a/parquet/src/arrow/async_reader/mod.rs
+++ b/parquet/src/arrow/async_reader/mod.rs
@@ -179,7 +179,7 @@ impl<T: AsyncRead + AsyncSeek + Unpin + Send> AsyncFileReader for T {
             let mut buffer = Vec::with_capacity(to_read);
             let read = self.take(to_read as u64).read_to_end(&mut buffer).await?;
             if read != to_read {
-                eof_err!("expected to read {} bytes, got {}", to_read, read);
+                return Err(eof_err!("expected to read {} bytes, got {}", to_read, read));
             }
 
             Ok(buffer.into())