系统表 distribution_queue 包含有关排队等待发送到分片的本地文件的信息。这些本地文件包含通过异步模式向分布式表插入新数据时创建的新 parts 文件。
字段名称 | 数据类型 | 字段含义说明 |
|---|---|---|
database | String | 数据库名称 |
table | String | 表名 |
data_path | String | 包含本地文件的文件夹路径 |
is_blocked | UInt8 | 表示向服务器发送本地文件是否被阻止 |
error_count | UInt64 | 错误数 |
data_files | UInt64 | 文件夹中的本地文件数量 |
data_compressed_bytes | UInt64 | 本地文件中压缩数据的大小,单位 bytes(字节) |
broken_data_files | UInt64 | 被标记为损坏(由于错误)的文件数量 |
broken_data_compressed_bytes | UInt64 | 损害文件中压缩数据的大小,单位 bytes(字节) |
last_exception | Sring | 最新发生的错误的文本消息(如果有的话) |
last_exception_time | DateTime | 最新发生错误的时间 |
SELECT * FROM system.distribution_queue LIMIT 1 FORMAT Vertical;
Row 1: ────── database: db_dorado_01 table: tb_dorado_01 data_path: /data00/clickhouse/data/store/416/416bcf77-931e-4e34-92de-496c90fc3938/shard2_all_replicas/ is_blocked: 0 error_count: 0 data_files: 0 data_compressed_bytes: 0 broken_data_files: 0 broken_data_compressed_bytes: 0 last_exception: last_exception_time: 1970-01-01 00:00:00