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

Merge pull request #6 from alexelex/quorum_inserts_2

Browse Source 
fix test_00814
This commit is contained in:
Latysheva Alexandra 2020-10-05 23:01:18 +06:00 committed by GitHub
commit 3b952aff7d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp
View File

@ -1764,7 +1764,13 @@ ReplicatedMergeTreeMergePredicate::ReplicatedMergeTreeMergePredicate(
Strings partitions = zookeeper->getChildren(queue.replica_path + "/parts"); Strings partitions = zookeeper->getChildren(queue.replica_path + "/parts");
for (const String & partition : partitions) for (const String & partition : partitions)
{ {
auto header = ReplicatedMergeTreePartHeader::fromString(zookeeper->get(queue.replica_path + "/parts/" + partition)); auto part_str = zookeeper->get(queue.replica_path + "/parts/" + partition);
if (part_str.empty())
{
/// use_minimalistic_part_header_in_zookeeper
continue;
}
auto header = ReplicatedMergeTreePartHeader::fromString(part_str);
if (header.getBlockID()) if (header.getBlockID())
{ {
ReplicatedMergeTreeBlockEntry block(zookeeper->get(queue.zookeeper_path + "/blocks/" + *header.getBlockID())); ReplicatedMergeTreeBlockEntry block(zookeeper->get(queue.zookeeper_path + "/blocks/" + *header.getBlockID()));