From 9b5620fac1e7fb5adb362acca872b91eabe77f8a Mon Sep 17 00:00:00 2001 From: VadimPE Date: Tue, 31 Jul 2018 12:01:24 +0300 Subject: [PATCH] CLICKHOUSE-3847 fix comments. --- .../Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp | 3 +-- dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h | 3 ++- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp index 707e1bc9d5c..47de65d7717 100644 --- a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp +++ b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp @@ -144,8 +144,7 @@ void ReplicatedMergeTreeCleanupThread::markLostReplicas(std::unordered_mapmulti(ops, responses); + auto code = zookeeper->multi(ops); } diff --git a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h index ec445323454..f1558d90499 100644 --- a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h +++ b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h @@ -39,7 +39,8 @@ private: /// Remove old records from ZooKeeper. void clearOldLogs(); - /// Mark lost replicas. + /// We don't want to keep logs for inactive replicas. + /// We mark these replicas as lost. void markLostReplicas(std::unordered_map log_pointers_lost_replicas, String min_record); /// Remove old block hashes from ZooKeeper. This is done by the leader replica.