database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[debug](ParquetReader) print file path if failed to read parquet file (#16118)

Browse Source
This commit is contained in:
Ashin Gau
2023-01-21 08:05:17 +08:00
committed by GitHub
parent 2daa5f3fef
commit de12957057
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/vec/exec/format/parquet/vparquet_reader.cpp
View File

@ -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();