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

style check

Browse Source
This commit is contained in:
Alexandra Latysheva 2020-10-07 12:24:46 +00:00
parent a43cac2c1a
commit 8f8872dc42
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Storages/MergeTree/ReplicatedMergeTreeBlockOutputStream.cpp
View File

@ -472,7 +472,7 @@ void ReplicatedMergeTreeBlockOutputStream::commitPart(
/// Check if this quorum insert is parallel or not
if (zookeeper->exists(storage.zookeeper_path + "/quorum/status"))
storage.updateQuorum(part->name, false);
else if (zookeeper->exists(storage.zookeeper_path + "/quorum/parallel/" + part->name))
else if (zookeeper->exists(storage.zookeeper_path + "/quorum/parallel/" + part->name))
storage.updateQuorum(part->name, true);
}

2
src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -3323,7 +3323,7 @@ bool StorageReplicatedMergeTree::fetchPart(const String & part_name, const Stora
/// Check if this quorum insert is parallel or not
if (zookeeper->exists(zookeeper_path + "/quorum/status"))
updateQuorum(part_name, false);
else if (zookeeper->exists(zookeeper_path + "/quorum/parallel/" + part_name))
else if (zookeeper->exists(zookeeper_path + "/quorum/parallel/" + part_name))
updateQuorum(part_name, true);
}