diff --git a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp index 9b802490e6a..7124b6bfda0 100644 --- a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp +++ b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp @@ -153,23 +153,6 @@ void ReplicatedMergeTreeCleanupThread::clearOldLogs() } -void ReplicatedMergeTreeCleanupThread::markLostReplicas(std::unordered_map log_pointers_lost_replicas, String remove_border) -{ - auto zookeeper = storage.getZooKeeper(); - - zkutil::Requests ops; - - for (auto pair : log_pointers_lost_replicas) - { - if ("log-" + padIndex(pair.second) <= remove_border) - ops.emplace_back(zkutil::makeCreateRequest(storage.zookeeper_path + "/replicas/" + pair.first + "/is_lost", "", - zkutil::CreateMode::Persistent)); - } - - auto code = zookeeper->multi(ops); -} - - struct ReplicatedMergeTreeCleanupThread::NodeWithStat { String node; diff --git a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h index 0154e7caf08..7d45a158c4c 100644 --- a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h +++ b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h @@ -39,10 +39,6 @@ private: /// Remove old records from ZooKeeper. void clearOldLogs(); - /// 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 remove_border); - /// Remove old block hashes from ZooKeeper. This is done by the leader replica. void clearOldBlocks();