From 0aec436ef8b690be2b5aac0eeb54ee68835ac117 Mon Sep 17 00:00:00 2001 From: Xiaocc <598887962@qq.com> Date: Sat, 18 Nov 2023 00:11:46 +0800 Subject: [PATCH] [chore](be) format reader parameter settings (#22964) --- be/src/olap/reader.cpp | 1 + be/src/vec/olap/block_reader.cpp | 1 - 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/olap/reader.cpp b/be/src/olap/reader.cpp index 90fda73799..75edcb0b97 100644 --- a/be/src/olap/reader.cpp +++ b/be/src/olap/reader.cpp @@ -255,6 +255,7 @@ Status TabletReader::_capture_rs_readers(const ReaderParams& read_params) { _reader_context.remaining_conjunct_roots = read_params.remaining_conjunct_roots; _reader_context.common_expr_ctxs_push_down = read_params.common_expr_ctxs_push_down; _reader_context.output_columns = &read_params.output_columns; + _reader_context.push_down_agg_type_opt = read_params.push_down_agg_type_opt; return Status::OK(); } diff --git a/be/src/vec/olap/block_reader.cpp b/be/src/vec/olap/block_reader.cpp index 33c065dce2..8602af091a 100644 --- a/be/src/vec/olap/block_reader.cpp +++ b/be/src/vec/olap/block_reader.cpp @@ -131,7 +131,6 @@ Status BlockReader::_init_collect_iter(const ReaderParams& read_params) { _vcollect_iter.init(this, _is_rowsets_overlapping, read_params.read_orderby_key, read_params.read_orderby_key_reverse); - _reader_context.push_down_agg_type_opt = read_params.push_down_agg_type_opt; std::vector valid_rs_readers; for (int i = 0; i < read_params.rs_splits.size(); ++i) {