From ee4d4c9b480ad77ac28624c3db0d3509b863e7d9 Mon Sep 17 00:00:00 2001 From: kakachen Date: Thu, 30 Oct 2025 13:36:30 +0800 Subject: [PATCH] [fix] (parquet-reader) Fix parquet all row groups are filtered. --- be/src/vec/exec/scan/file_scanner.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/be/src/vec/exec/scan/file_scanner.cpp b/be/src/vec/exec/scan/file_scanner.cpp index c0b440fa6f301f..cb2377fe613430 100644 --- a/be/src/vec/exec/scan/file_scanner.cpp +++ b/be/src/vec/exec/scan/file_scanner.cpp @@ -1171,7 +1171,13 @@ Status FileScanner::_get_next_reader() { // to filter the row group. But if this is count push down, the offset is undefined, // causing incorrect row group filter and may return empty result. } else { - RETURN_IF_ERROR(_set_fill_or_truncate_columns(need_to_get_parsed_schema)); + Status status = _set_fill_or_truncate_columns(need_to_get_parsed_schema); + if (status.is()) { // all parquet row groups are filtered + continue; + } else if (!status.ok()) { + return Status::InternalError("failed to set_fill_or_truncate_columns, err: {}", + status.to_string()); + } } _cur_reader_eof = false; break;