Skip to content

Commit

Permalink
fix compile
Browse files Browse the repository at this point in the history
  • Loading branch information
bobhan1 committed Dec 20, 2024
1 parent fe3e5c9 commit c9f2159
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions be/src/olap/base_tablet.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1116,8 +1116,9 @@ Status BaseTablet::generate_new_block_for_flexible_partial_update(
const signed char* delete_sign_column_data) {
if (skipped) {
bool use_default = false;
bool old_row_delete_sign = (delete_sign_column_data != nullptr &&
delete_sign_column_data[read_index_old[cast_set<uint32_t>(idx)]] != 0);
bool old_row_delete_sign =
(delete_sign_column_data != nullptr &&
delete_sign_column_data[read_index_old[cast_set<uint32_t>(idx)]] != 0);
if (old_row_delete_sign) {
if (!rowset_schema->has_sequence_col()) {
use_default = true;
Expand All @@ -1144,15 +1145,15 @@ Status BaseTablet::generate_new_block_for_flexible_partial_update(
// - if the previous conflicting row is deleted, we should use the value in current block as its final value
// - if the previous conflicting row is an insert, we should use the value in old block as its final value to
// keep consistency between replicas
new_col->insert_from(cur_col, read_index_update[idx]);
new_col->insert_from(cur_col, read_index_update[cast_set<uint32_t>(idx)]);
} else {
new_col->insert_default();
}
} else {
new_col->insert_from(old_value_col, read_index_old[idx]);
new_col->insert_from(old_value_col, read_index_old[cast_set<uint32_t>(idx)]);
}
} else {
new_col->insert_from(cur_col, read_index_update[idx]);
new_col->insert_from(cur_col, read_index_update[cast_set<uint32_t>(idx)]);
}
};

Expand Down

0 comments on commit c9f2159

Please sign in to comment.