Skip to content

Commit

Permalink
fix coredump
Browse files Browse the repository at this point in the history
  • Loading branch information
airborne12 committed Sep 28, 2024
1 parent 9d1ad41 commit 2edb5ff
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions be/src/olap/rowset/segment_v2/segment_iterator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2198,14 +2198,12 @@ Status SegmentIterator::_next_batch_internal(vectorized::Block* block) {
auto col_const = vectorized::ColumnConst::create(std::move(res_column),
selected_size);
block->replace_by_position(0, std::move(col_const));
_output_index_result_column_for_expr(_sel_rowid_idx.data(), selected_size,
block);
_output_index_result_column_for_expr(sel_rowid_idx, selected_size, block);
block->shrink_char_type_column_suffix_zero(_char_type_idx_no_0);
RETURN_IF_ERROR(_execute_common_expr(sel_rowid_idx, selected_size, block));
block->replace_by_position(0, std::move(col0));
} else {
_output_index_result_column_for_expr(_sel_rowid_idx.data(), selected_size,
block);
_output_index_result_column_for_expr(sel_rowid_idx, selected_size, block);
block->shrink_char_type_column_suffix_zero(_char_type_idx);
RETURN_IF_ERROR(_execute_common_expr(sel_rowid_idx, selected_size, block));
}
Expand Down Expand Up @@ -2237,12 +2235,12 @@ Status SegmentIterator::_next_batch_internal(vectorized::Block* block) {
auto col_const =
vectorized::ColumnConst::create(std::move(res_column), selected_size);
block->replace_by_position(0, std::move(col_const));
_output_index_result_column_for_expr(_sel_rowid_idx.data(), selected_size, block);
_output_index_result_column_for_expr(sel_rowid_idx, selected_size, block);
block->shrink_char_type_column_suffix_zero(_char_type_idx_no_0);
RETURN_IF_ERROR(_execute_common_expr(sel_rowid_idx, selected_size, block));
block->replace_by_position(0, std::move(col0));
} else {
_output_index_result_column_for_expr(_sel_rowid_idx.data(), selected_size, block);
_output_index_result_column_for_expr(sel_rowid_idx, selected_size, block);
block->shrink_char_type_column_suffix_zero(_char_type_idx);
RETURN_IF_ERROR(_execute_common_expr(sel_rowid_idx, selected_size, block));
}
Expand Down

0 comments on commit 2edb5ff

Please sign in to comment.