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

Merge pull request #12 from alexelex/quorum_inserts_2

Browse Source 
style check
This commit is contained in:
Latysheva Alexandra 2020-10-07 18:56:14 +06:00 committed by GitHub
commit f43ad338ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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

@ -3325,7 +3325,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);
}