diff --git a/be/src/exec/parquet_scanner.cpp b/be/src/exec/parquet_scanner.cpp index 2db36f3f4bc1ee..adad61e9b0e134 100644 --- a/be/src/exec/parquet_scanner.cpp +++ b/be/src/exec/parquet_scanner.cpp @@ -152,11 +152,17 @@ Status ParquetScanner::open_next_reader() { } Status status = _cur_file_reader->init_parquet_reader(_src_slot_descs, _state->timezone()); - + if (status.is_end_of_file()) { continue; } else { - return status; + if (!status.ok()) { + std::stringstream ss; + ss << " file: " << range.path << " error:" << status.get_error_msg(); + return Status::InternalError(ss.str()); + } else { + return status; + } } } }