From 2be62bbd1b72321c1a155a80cf30cc80733d1752 Mon Sep 17 00:00:00 2001 From: Alexandra Latysheva Date: Mon, 5 Oct 2020 16:58:26 +0000 Subject: [PATCH] fix test_00814 --- src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp b/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp index 128fcb66f96..c88172f0701 100644 --- a/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp +++ b/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp @@ -1764,7 +1764,13 @@ ReplicatedMergeTreeMergePredicate::ReplicatedMergeTreeMergePredicate( Strings partitions = zookeeper->getChildren(queue.replica_path + "/parts"); 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()) { ReplicatedMergeTreeBlockEntry block(zookeeper->get(queue.zookeeper_path + "/blocks/" + *header.getBlockID()));