You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/11/08 07:41:06 UTC
[doris] 05/09: [feature-wip](multi-catalog) fix page index filter bug (#14015)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-unstable
in repository https://gitbox.apache.org/repos/asf/doris.git
commit b4857cb608b4b27d8e5deb047271a2c432236dbe
Author: slothever <18...@users.noreply.github.com>
AuthorDate: Tue Nov 8 12:10:12 2022 +0800
[feature-wip](multi-catalog) fix page index filter bug (#14015)
Fix page index filter not take effect when multiple columns
Co-authored-by: jinzhe <ji...@selectdb.com>
---
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/vec/exec/format/parquet/vparquet_reader.cpp b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
index dc33f321d7..af899fb318 100644
--- a/be/src/vec/exec/format/parquet/vparquet_reader.cpp
+++ b/be/src/vec/exec/format/parquet/vparquet_reader.cpp
@@ -337,7 +337,7 @@ Status ParquetReader::_process_page_index(const tparquet::RowGroup& row_group,
page_index.collect_skipped_page_range(&column_index, conjuncts, col_schema,
skipped_page_range);
if (skipped_page_range.empty()) {
- return Status::OK();
+ break;
}
tparquet::OffsetIndex offset_index;
RETURN_IF_ERROR(page_index.parse_offset_index(chunk, buff, buffer_size, &offset_index));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org