diff --git a/be/src/vec/olap/block_reader.cpp b/be/src/vec/olap/block_reader.cpp index ab187367f9..abef78014b 100644 --- a/be/src/vec/olap/block_reader.cpp +++ b/be/src/vec/olap/block_reader.cpp @@ -106,8 +106,14 @@ void BlockReader::_init_agg_state(const ReaderParams& read_params) { Status BlockReader::init(const ReaderParams& read_params) { TabletReader::init(read_params); - auto return_column_size = - read_params.origin_return_columns->size() - (_sequence_col_idx != -1 ? 1 : 0); + int32_t return_column_size = 0; + // read sequence column if not reader_query + if (read_params.reader_type != ReaderType::READER_QUERY) { + return_column_size = read_params.origin_return_columns->size(); + } else { + return_column_size = + read_params.origin_return_columns->size() - (_sequence_col_idx != -1 ? 1 : 0); + } _return_columns_loc.resize(read_params.return_columns.size()); for (int i = 0; i < return_column_size; ++i) { auto cid = read_params.origin_return_columns->at(i);