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

Attempt to fix an error with yielding leadership [#METR-20691].

Browse Source
This commit is contained in:
Alexey Milovidov 2016-04-03 00:22:39 +03:00
parent 22272510dc
commit f2edb5d1fb
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
dbms/src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -3342,7 +3342,7 @@ void StorageReplicatedMergeTree::getReplicaDelays(time_t & out_absolute_delay, t
out_absolute_delay = current_time - min_unprocessed_insert_time;
/** Относительная задержка - максимальная разница абсолютной задержки от какой-либо другой реплики,
* (если эта реплика отстаёт от какой-либо другой реплики, или ноль, иначе).
* (если эта реплика отстаёт от какой-либо другой живой реплики, или ноль, иначе).
* Вычисляется только если абсолютная задержка достаточно большая.
*/
@ -3361,6 +3361,10 @@ void StorageReplicatedMergeTree::getReplicaDelays(time_t & out_absolute_delay, t
if (replica == replica_name)
continue;
/// Пропускаем неживые реплики.
if (!zookeeper->exists(zookeeper_path + "/replicas/" + replica + "/is_active"))
continue;
String value;
if (!zookeeper->tryGet(zookeeper_path + "/replicas/" + replica + "/min_unprocessed_insert_time", value))
continue;
@ -3369,6 +3373,14 @@ void StorageReplicatedMergeTree::getReplicaDelays(time_t & out_absolute_delay, t
if (replica_time == 0)
{
/** Замечание:
* Вывод о том, что реплика не отстаёт, может быть неверен,
* потому что информация о min_unprocessed_insert_time берётся
* только из той части лога, которая перенесена в очередь.
* Если у реплики почему-то не работает queueUpdatingThread,
* то и min_unprocessed_insert_time будет неправильным.
*/
have_replica_with_nothing_unprocessed = true;
break;
}