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

temp-commit

Browse Source
This commit is contained in:
Konstantin Bogdanov 2024-08-11 23:35:44 +02:00
parent aec1acd0d4
commit c02546e9c3
No known key found for this signature in database
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Server/ACMEClient.cpp
View File

@ -4,6 +4,7 @@
#include <Common/logger_useful.h>
#include "Core/BackgroundSchedulePool.h"
#include "Interpreters/Context.h"
#include "Storages/MergeTree/LeaderElection.h"
#include <IO/ReadBufferFromFile.h>
#include <IO/ReadHelpers.h>
#include <IO/S3/Credentials.h>
@ -16,10 +17,6 @@
namespace DB
{
// namespace ErrorCodes
// {
// // extern const int LOGICAL_ERROR;
// }
namespace ACMEClient
{
@ -59,7 +56,7 @@ try
auto context = Context::getGlobalContextInstance();
auto zk = context->getZooKeeper();
zk->createIfNotExists("/acme", "");
zk->createIfNotExists("/clickhouse/acme", "");
BackgroundSchedulePool & bgpool = context->getSchedulePool();
@ -68,6 +65,7 @@ try
election_task->scheduleAfter(1000);
zkutil::checkNoOldLeaders(log, *zk, fs::path("/clickhouse/acme") / "leader_election");
auto leader = zkutil::EphemeralNodeHolder::tryCreate("/acme/leader", *zk);
if (leader)
leader_node = std::move(leader);