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

cosmetic

Browse Source
This commit is contained in:
Guillaume Tassery 2019-08-30 06:35:56 +02:00
parent d752b1c143
commit 87b8f89600
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5163,12 +5163,18 @@ void StorageReplicatedMergeTree::movePartitionTo(const StoragePtr & dest_table,
if (context.getSettingsRef().replication_alter_partitions_sync > 1)
dest_table_storage->waitForAllReplicasToProcessLogEntry(entry);
Coordination::Requests ops_dest;
Coordination::Requests ops_dest;
ops_dest.emplace_back(zkutil::makeCreateRequest(zookeeper_path + "/log/log-", entry_delete.toString(), zkutil::CreateMode::PersistentSequential));
zookeeper->multi(ops_dest);
}
ops_results = zookeeper->multi(ops_dest);
String log_znode_path = dynamic_cast<const Coordination::CreateResponse &>(*op_results.back()).path_created;
entry_delete.znode_name = log_znode_path.substr(log_znode_path.find_last_of('/') + 1);
if (context.getSettingsRef().replication_alter_partitions_sync > 1)
waitForAllReplicasToProcessLogEntry(entry_delete);
}
void StorageReplicatedMergeTree::getCommitPartOps(
Coordination::Requests & ops,