thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-23 10:10:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

CLICKHOUSE-3847 Del markLosrTeplicas()

Browse Source
This commit is contained in:
VadimPE 2018-08-07 18:26:27 +03:00
parent 32b6965cf2
commit 0be75baeda
2 changed files with 0 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.cpp
View File

@ -153,23 +153,6 @@ void ReplicatedMergeTreeCleanupThread::clearOldLogs()
}
void ReplicatedMergeTreeCleanupThread::markLostReplicas(std::unordered_map<String, UInt64> 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;

4
dbms/src/Storages/MergeTree/ReplicatedMergeTreeCleanupThread.h
View File

@ -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<String, UInt64> log_pointers_lost_replicas, String remove_border);
/// Remove old block hashes from ZooKeeper. This is done by the leader replica.
void clearOldBlocks();