diff --git a/be/src/cloud/cloud_schema_change_job.cpp b/be/src/cloud/cloud_schema_change_job.cpp index 42593d4d4137e2..444302e3c6c727 100644 --- a/be/src/cloud/cloud_schema_change_job.cpp +++ b/be/src/cloud/cloud_schema_change_job.cpp @@ -466,6 +466,10 @@ Status CloudSchemaChangeJob::_process_delete_bitmap(int64_t alter_version, {start_calc_delete_bitmap_version, max_version}, &incremental_rowsets)); DBUG_EXECUTE_IF("CloudSchemaChangeJob::_process_delete_bitmap.after.capture_without_lock", DBUG_BLOCK); + { + std::unique_lock wlock(tmp_tablet->get_header_lock()); + tmp_tablet->add_rowsets(_output_rowsets, true, wlock); + } for (auto rowset : incremental_rowsets) { RETURN_IF_ERROR(CloudTablet::update_delete_bitmap_without_lock(tmp_tablet, rowset)); }