Skip to content

Commit dbb147c

Browse files
committed
fix
1 parent fa82d90 commit dbb147c

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

be/src/cloud/cloud_schema_change_job.cpp

+4
Original file line numberDiff line numberDiff line change
@@ -493,6 +493,10 @@ Status CloudSchemaChangeJob::_process_delete_bitmap(int64_t alter_version,
493493
{start_calc_delete_bitmap_version, max_version}, &incremental_rowsets));
494494
DBUG_EXECUTE_IF("CloudSchemaChangeJob::_process_delete_bitmap.after.capture_without_lock",
495495
DBUG_BLOCK);
496+
{
497+
std::unique_lock wlock(tmp_tablet->get_header_lock());
498+
tmp_tablet->add_rowsets(_output_rowsets, true, wlock);
499+
}
496500
for (auto rowset : incremental_rowsets) {
497501
RETURN_IF_ERROR(CloudTablet::update_delete_bitmap_without_lock(tmp_tablet, rowset));
498502
}

0 commit comments

Comments
 (0)