system.replication_queue
Содержит информацию о задачах из очередей репликации, хранящихся в ClickHouse Keeper или ZooKeeper, для таблиц из семейства ReplicatedMergeTree.
Колонки:
-
database(String) — Название базы данных. -
table(String) — Название таблицы. -
replica_name(String) — Имя реплики в ClickHouse Keeper. У разных реплик одной и той же таблицы разные имена. -
position(UInt32) — Позиция задачи в очереди. -
node_name(String) — Имя узла в ClickHouse Keeper. -
type(String) — Тип задачи в очереди, один из следующих:GET_PART— Получить часть от другой реплики.ATTACH_PART— Присоединить часть, возможно, из нашей собственной реплики (если найдена в папкеdetached). Вы можете рассматривать это какGET_PARTс некоторыми оптимизациями, так как они почти идентичны.MERGE_PARTS— Объединить части.DROP_RANGE— Удалить части в указанной партиции в указанном диапазоне.CLEAR_COLUMN— ПРИМЕЧАНИЕ: Устарело. Удалить конкретную колонку из указанной партиции.CLEAR_INDEX— ПРИМЕЧАНИЕ: Устарело. Удалить конкретный индекс из указанной партиции.REPLACE_RANGE— Удалить определенный диапазон частей и заменить их новыми.MUTATE_PART— Применить одну или несколько мутаций к части.ALTER_METADATA— Применить модификацию изменения в соответствии с глобальными путями /metadata и /columns.
-
create_time(DateTime) — Дата и время, когда задача была подана на выполнение. -
required_quorum(UInt32) — Количество реплик, ожидающих завершения задачи с подтверждением выполнения. Этот столбец актуален только для задачиGET_PARTS. -
source_replica(String) — Имя исходной реплики. -
new_part_name(String) — Имя новой части. -
parts_to_merge(Array (String)) — Названия частей для объединения или обновления. -
is_detach(UInt8) — Флаг, указывающий, находится ли задачаDETACH_PARTSв очереди. -
is_currently_executing(UInt8) — Флаг, указывающий, выполняется ли конкретная задача в данный момент. -
num_tries(UInt32) — Количество неудачных попыток завершить задачу. -
last_exception(String) — Текстовое сообщение о последней возникшей ошибке (если таковая была). -
last_attempt_time(DateTime) — Дата и время, когда задача была в последний раз предпринята. -
num_postponed(UInt32) — Количество раз, когда действие было отложено. -
postpone_reason(String) — Причина, по которой задача была отложена. -
last_postpone_time(DateTime) — Дата и время, когда задача была в последний раз отложена. -
merge_type(String) — Тип текущего слияния. Пусто, если это мутация.
Пример
Смотрите также