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

Fix obvious bug

Browse Source
This commit is contained in:
alesapin 2021-04-16 16:53:48 +03:00
parent f168bfae6d
commit e724952c03
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/Coordination/KeeperStorageDispatcher.cpp
View File

@ -58,7 +58,7 @@ void KeeperStorageDispatcher::requestThread()
/// If new request is not read request or we must to process it through quorum.
/// Otherwise we will process it locally.
if (coordination_settings->quorum_reads || !request.request->isReadRequest() || !server->isLeaderAlive())
if (coordination_settings->quorum_reads || !request.request->isReadRequest())
{
current_batch.emplace_back(request);
@ -69,7 +69,7 @@ void KeeperStorageDispatcher::requestThread()
if (requests_queue->tryPop(request, 1))
{
/// Don't append read request into batch, we have to process them separately
if (!coordination_settings->quorum_reads && request.request->isReadRequest() && server->isLeaderAlive())
if (!coordination_settings->quorum_reads && request.request->isReadRequest())
{
has_read_request = true;
break;
@ -111,9 +111,7 @@ void KeeperStorageDispatcher::requestThread()
}
/// Read request always goes after write batch (last request)
/// We don't check leader aliveness, because it was alive when this request happen
/// so our state is consistent.
if (has_read_request)
if (has_read_request && server->isLeaderAlive())
server->putLocalReadRequest(request);
}
}