Skip to content

Commit 7d6d563

Browse files
committed
_do_lazy_read
1 parent 8f40d03 commit 7d6d563

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

be/src/vec/exec/format/parquet/vparquet_group_reader.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
#include "runtime/types.h"
4141
#include "schema_desc.h"
4242
#include "vec/columns/column_const.h"
43+
#include "vec/columns/column_nothing.h"
4344
#include "vec/columns/column_nullable.h"
4445
#include "vec/columns/column_string.h"
4546
#include "vec/columns/column_vector.h"
@@ -484,8 +485,7 @@ Status RowGroupReader::_do_lazy_read(Block* block, size_t batch_size, size_t* re
484485
// generate filter vector
485486
if (_lazy_read_ctx.resize_first_column) {
486487
// VExprContext.execute has an optimization, the filtering is executed when block->rows() > 0
487-
// The following process may be tricky and time-consuming, but we have no other way.
488-
block->get_by_position(0).column->assume_mutable()->resize(pre_read_rows);
488+
block->get_by_position(0).column = ColumnNothing::create(pre_read_rows);
489489
}
490490
result_filter.assign(pre_read_rows, static_cast<unsigned char>(1));
491491
std::vector<IColumn::Filter*> filters;

0 commit comments

Comments
 (0)