Skip to content

Commit

Permalink
[Opt](delete) Skip newly inserted rows check in non-strict mode parti…
Browse files Browse the repository at this point in the history
…al update if the row's delete sign is marked (apache#40322)
  • Loading branch information
bobhan1 authored Sep 4, 2024
1 parent edb6eec commit 3856aca
Show file tree
Hide file tree
Showing 5 changed files with 527 additions and 112 deletions.
3 changes: 2 additions & 1 deletion be/src/olap/rowset/segment_v2/segment_writer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -596,7 +596,8 @@ Status SegmentWriter::append_block_with_partial_content(const vectorized::Block*
segment_pos);

} else {
if (!_opts.rowset_ctx->partial_update_info->can_insert_new_rows_in_partial_update) {
if (!_opts.rowset_ctx->partial_update_info->can_insert_new_rows_in_partial_update &&
!have_delete_sign) {
std::string error_column;
for (auto cid : _opts.rowset_ctx->partial_update_info->missing_cids) {
const TabletColumn& col = _tablet_schema->column(cid);
Expand Down
3 changes: 2 additions & 1 deletion be/src/olap/rowset/segment_v2/vertical_segment_writer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -455,7 +455,8 @@ Status VerticalSegmentWriter::_append_block_with_partial_content(RowsInBlock& da
DeleteBitmap::TEMP_VERSION_COMMON},
segment_pos);
} else {
if (!_opts.rowset_ctx->partial_update_info->can_insert_new_rows_in_partial_update) {
if (!_opts.rowset_ctx->partial_update_info->can_insert_new_rows_in_partial_update &&
!have_delete_sign) {
std::string error_column;
for (auto cid : _opts.rowset_ctx->partial_update_info->missing_cids) {
const TabletColumn& col = _tablet_schema->column(cid);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
1
2
3
3
7
Loading

0 comments on commit 3856aca

Please sign in to comment.