mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-30 05:30:51 +00:00
put back lock
This commit is contained in:
parent
552e3b8400
commit
d38bc27c05
@ -1228,7 +1228,7 @@ void StorageMergeTree::movePartitionToTable(const StoragePtr & dest_table, const
|
||||
for (MutableDataPartPtr & part : dst_parts)
|
||||
dest_table_storage->renameTempPartAndReplace(part, &increment, &transaction, dest_data_parts_lock);
|
||||
|
||||
removePartsFromWorkingSet(src_parts, true, src_data_parts_lock);
|
||||
removePartsFromWorkingSet(src_parts, true, dest_data_parts_lock);
|
||||
transaction.commit(&dest_data_parts_lock);
|
||||
}
|
||||
|
||||
|
@ -5115,7 +5115,7 @@ void StorageReplicatedMergeTree::movePartitionToTable(const StoragePtr & dest_ta
|
||||
|
||||
op_results = zookeeper->multi(ops);
|
||||
|
||||
parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, src_data_parts_lock);
|
||||
parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, dest_data_parts_lock);
|
||||
transaction.commit(&dest_data_parts_lock);
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user