You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2023/01/21 00:05:23 UTC
[doris] branch master updated: [debug](ParquetReader) print file path if failed to read parquet file (#16118)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new de12957057 [debug](ParquetReader) print file path if failed to read parquet file (#16118)
de12957057 is described below
commit de129570571892ad00a8b12ace803988eef1bc0c
Author: Ashin Gau <As...@users.noreply.github.com>
AuthorDate: Sat Jan 21 08:05:17 2023 +0800
[debug](ParquetReader) print file path if failed to read parquet file (#16118)
---
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/be/src/vec/exec/format/parquet/vparquet_reader.cpp b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
index 1bedf556c0..35936364b3 100644
--- a/be/src/vec/exec/format/parquet/vparquet_reader.cpp
+++ b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
@@ -402,8 +402,12 @@ Status ParquetReader::get_next_block(Block* block, size_t* read_rows, bool* eof)
DCHECK(_current_group_reader != nullptr);
{
SCOPED_RAW_TIMER(&_statistics.column_read_time);
- RETURN_IF_ERROR(
- _current_group_reader->next_batch(block, _batch_size, read_rows, &_row_group_eof));
+ Status batch_st =
+ _current_group_reader->next_batch(block, _batch_size, read_rows, &_row_group_eof);
+ if (!batch_st.ok()) {
+ return Status::InternalError("Read parquet file {} failed, reason = {}",
+ _scan_range.path, batch_st.to_string());
+ }
}
if (_row_group_eof) {
auto column_st = _current_group_reader->statistics();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org