Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
dataroaring committed Sep 13, 2023
1 parent 9c0ede1 commit f62e24d
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions be/src/vec/olap/vcollect_iterator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -489,14 +489,15 @@ int64_t VCollectIterator::Level0Iterator::version() const {

Status VCollectIterator::Level0Iterator::refresh_current_row() {
do {
if (_block == nullptr && !_get_data_by_ref) {
_block = std::make_shared<Block>(_schema.create_block(
_reader->_return_columns, _reader->_tablet_columns_convert_to_null_set));
}

if (!_is_empty() && _current_valid()) {
return Status::OK();
} else {
_reset();
if (_block == nullptr && !_get_data_by_ref) {
_block = std::make_shared<Block>(_schema.create_block(
_reader->_return_columns, _reader->_tablet_columns_convert_to_null_set));
}
auto res = _refresh();
if (!res.ok() && !res.is<END_OF_FILE>()) {
return res;
Expand Down

0 comments on commit f62e24d

Please sign in to comment.