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

check for active replicas when waiting for commands

Browse Source
This commit is contained in:
Javi santana bot 2019-12-20 11:00:21 +01:00
parent b864bc49b9
commit dd5435501a
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3844,9 +3844,15 @@ void StorageReplicatedMergeTree::waitForAllReplicasToProcessLogEntry(const Repli
{ {
LOG_DEBUG(log, "Waiting for all replicas to process " << entry.znode_name); LOG_DEBUG(log, "Waiting for all replicas to process " << entry.znode_name);
Strings replicas = getZooKeeper()->getChildren(zookeeper_path + "/replicas"); auto zookeeper = getZooKeeper()
Strings replicas = zookeeper->getChildren(zookeeper_path + "/replicas");
for (const String & replica : replicas) for (const String & replica : replicas)
waitForReplicaToProcessLogEntry(replica, entry); {
if (zookeeper->exists(zookeeper_path + "/replicas/" + replica + "/is_active"))
{
waitForReplicaToProcessLogEntry(replica, entry);
}
}
LOG_DEBUG(log, "Finished waiting for all replicas to process " << entry.znode_name); LOG_DEBUG(log, "Finished waiting for all replicas to process " << entry.znode_name);
} }