Перейти к основному содержанию
Перейти к основному содержанию

system.distribution_queue

Содержит информацию о локальных файлах, которые находятся в очереди на отправку шардам. Эти локальные файлы содержат новые части, создаваемые при асинхронной вставке новых данных в таблицу Distributed.

Столбцы:

  • database (String) — Имя базы данных.
  • table (String) — Имя таблицы.
  • data_path (String) — Путь к папке с локальными файлами.
  • is_blocked (UInt8) — Флаг, показывающий, заблокирована ли отправка локальных файлов на сервер.
  • error_count (UInt64) — Количество ошибок.
  • data_files (UInt64) — Количество локальных файлов в папке.
  • data_compressed_bytes (UInt64) — Размер сжатых данных в локальных файлах, в байтах.
  • broken_data_files (UInt64) — Количество файлов, помеченных как повреждённые (из‑за ошибки).
  • broken_data_compressed_bytes (UInt64) — Размер сжатых данных в повреждённых файлах, в байтах.
  • last_exception (String) — Текстовое сообщение о последней возникшей ошибке (если она была).
  • last_exception_time (DateTime) — Время возникновения последнего исключения.

Пример

SELECT * FROM system.distribution_queue LIMIT 1 FORMAT Vertical;

Строка 1:
──────
база_данных:           default
таблица:               dist
путь_данных:           ./store/268/268bc070-3aad-4b1a-9cf2-4987580161af/default@127%2E0%2E0%2E2:9000/
заблокирована:         1
количество_ошибок:     0
файлов_данных:         1
сжатых_байт_данных:    499
последнее_исключение:

См. также