thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 23:52:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Trying to disable suspicious parameter

Browse Source
This commit is contained in:
alesapin 2021-02-04 22:29:46 +03:00
parent 933105a667
commit c5312bf362
4 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Coordination/NuKeeperServer.cpp
View File

@ -43,7 +43,7 @@ void NuKeeperServer::addServer(int server_id_, const std::string & server_uri_,
}
void NuKeeperServer::startup()
void NuKeeperServer::startup(int64_t operation_timeout_ms)
{
nuraft::raft_params params;
params.heart_beat_interval_ = 500;
@ -51,8 +51,10 @@ void NuKeeperServer::startup()
params.election_timeout_upper_bound_ = 2000;
params.reserved_log_items_ = 5000;
params.snapshot_distance_ = 5000;
params.client_req_timeout_ = 10000;
params.client_req_timeout_ = operation_timeout_ms;
params.auto_forwarding_ = true;
/// For some reason may lead to a very long timeouts
params.use_bg_thread_for_urgent_commit_ = false;
params.return_method_ = nuraft::raft_params::blocking;
nuraft::asio_service::options asio_opts{};
@ -197,6 +199,7 @@ int64_t NuKeeperServer::getSessionID(int64_t session_timeout_ms)
std::lock_guard lock(append_entries_mutex);
auto result = raft_instance->append_entries({entry});
if (!result->get_accepted())
throw Exception(ErrorCodes::RAFT_ERROR, "Cannot send session_id request to RAFT");

2
src/Coordination/NuKeeperServer.h
View File

@ -34,7 +34,7 @@ private:
public:
NuKeeperServer(int server_id_, const std::string & hostname_, int port_);
void startup();
void startup(int64_t operation_timeout_ms);
NuKeeperStorage::ResponsesForSessions putRequest(const NuKeeperStorage::RequestForSession & request);

3
src/Coordination/NuKeeperStorageDispatcher.cpp
View File

@ -111,6 +111,7 @@ void NuKeeperStorageDispatcher::initialize(const Poco::Util::AbstractConfigurati
int myport;
int32_t my_priority = 1;
operation_timeout = Poco::Timespan(0, config.getUInt("test_keeper_server.operation_timeout_ms", Coordination::DEFAULT_OPERATION_TIMEOUT_MS) * 1000);
Poco::Util::AbstractConfiguration::Keys keys;
config.keys("test_keeper_server.raft_configuration", keys);
bool my_can_become_leader = true;
@ -141,7 +142,7 @@ void NuKeeperStorageDispatcher::initialize(const Poco::Util::AbstractConfigurati
server = std::make_unique<NuKeeperServer>(myid, myhostname, myport);
try
{
server->startup();
server->startup(operation_timeout.totalMilliseconds());
if (shouldBuildQuorum(myid, my_priority, my_can_become_leader, server_configs))
{
for (const auto & [id, hostname, port, can_become_leader, priority] : server_configs)

2
src/Server/NuKeeperTCPHandler.cpp
View File

@ -331,7 +331,9 @@ void NuKeeperTCPHandler::runImpl()
{
try
{
LOG_INFO(log, "Requesting session ID for the new client");
session_id = nu_keeper_storage_dispatcher->getSessionID(session_timeout.totalMilliseconds());
LOG_INFO(log, "Received session ID {}", session_id);
}
catch (const Exception & e)
{