thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-14 10:22:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

release lock

Browse Source
This commit is contained in:
Guillaume Tassery 2019-11-21 09:04:22 +01:00
parent 8239873605
commit ebee0ab09a
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5172,7 +5172,10 @@ void StorageReplicatedMergeTree::movePartitionToTable(const StoragePtr & dest_ta
cleanup_thread.wakeup();
if (context.getSettingsRef().replication_alter_partitions_sync > 1)
{
lock2.release();
dest_table_storage->waitForAllReplicasToProcessLogEntry(entry);
}
Coordination::Requests ops_dest;
@ -5184,7 +5187,10 @@ void StorageReplicatedMergeTree::movePartitionToTable(const StoragePtr & dest_ta
entry_delete.znode_name = log_znode_path.substr(log_znode_path.find_last_of('/') + 1);
if (context.getSettingsRef().replication_alter_partitions_sync > 1)
{
lock1.release();
waitForAllReplicasToProcessLogEntry(entry_delete);
}
}
void StorageReplicatedMergeTree::getCommitPartOps(