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

system.distribution_queue

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

Колонки:

  • 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) — Текстовое сообщение о последней произошедшей ошибке (если такая имеется).

Пример

SELECT * FROM system.distribution_queue LIMIT 1 FORMAT Vertical;
Row 1:
──────
database:              default
table:                 dist
data_path:             ./store/268/268bc070-3aad-4b1a-9cf2-4987580161af/default@127%2E0%2E0%2E2:9000/
is_blocked:            1
error_count:           0
data_files:            1
data_compressed_bytes: 499
last_exception:

См. также