thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-18 13:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix lock

Browse Source
This commit is contained in:
Guillaume Tassery 2019-10-11 08:11:53 +02:00
parent 0f66da0e91
commit 145df0bb65
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Storages/StorageMergeTree.cpp
View File

@ -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, dest_data_parts_lock);
removePartsFromWorkingSet(src_parts, true, src_data_parts_lock);
transaction.commit(&dest_data_parts_lock);
}

2
dbms/src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -5115,7 +5115,7 @@ void StorageReplicatedMergeTree::movePartitionToTable(const StoragePtr & dest_ta
op_results = zookeeper->multi(ops);
parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, dest_data_parts_lock);
parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, src_data_parts_lock);
transaction.commit(&dest_data_parts_lock);
}