system.distribution_queue

Contient des informations sur les fichiers locaux en attente d’envoi vers les shards. Ces fichiers locaux contiennent de nouvelles parts créées lors de l’insertion de nouvelles données dans la table Distributed en mode asynchrone.

• database (String) — Nom de la base de données.
• table (String) — Nom de la table.
• data_path (String) — Chemin vers le dossier contenant les fichiers locaux.
• is_blocked (UInt8) — Indique si l’envoi de fichiers locaux au serveur est bloqué.
• error_count (UInt64) — Nombre d’erreurs.
• data_files (UInt64) — Nombre de fichiers locaux dans un dossier.
• data_compressed_bytes (UInt64) — Taille, en octets, des données compressées contenues dans les fichiers locaux.
• broken_data_files (UInt64) — Nombre de fichiers marqués comme corrompus en raison d’une erreur.
• broken_data_compressed_bytes (UInt64) — Taille, en octets, des données compressées contenues dans les fichiers corrompus.
• last_exception (String) — Message de la dernière erreur survenue, le cas échéant.
• last_exception_time (DateTime) — Heure de la dernière exception.

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:

• Moteur de table Distributed