跳到主要内容
跳到主要内容

system.distribution_queue

包含队列中待发送到分片的本地文件的信息。这些本地文件包含在异步模式下向 Distributed 表插入新数据时创建的新数据片段（parts）。

列：

  • 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;

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:

另请参阅