ha_queue 展示了 HaMergeTree 表未完成的 log entry 的状态。
字段名称 | 数据类型 | 字段含义说明 |
|---|---|---|
type | String | Log entry 对应的类型，如 clone_part、get_part、merge_parts 等。 |
lsn | UInt32 | Log entry 对应的 lsn 号。 |
create_time | DateTime | Log entry 的创建时间。 |
source_replica | String | 创建 log entry 的 replica。 |
new_part_name | String | Log entry 会产生的新的 part 的名称。 |
parts_to_merge | Array(String) | 如果是 merge_parts，需要 merge 的 source part。 |
total_rows | UInt64 | merge_parts/mutate_part 对应的 source part 的总行数。 |
total_size | UInt64 | merge_parts/mutate_part 对应的 source part 的总大小。 |
is_currently_executing | UInt8 | 当前是否正在执行。 |
num_tries | UInt32 | Log entry 已经运行了多少次。 |
first_attempt_time | DateTime | 第一次运行的时间。 |
last_attempt_time | DateTime | 最后一次运行的时间。 |
last_exception_time | DateTime | 最后一次遇到异常的时间。 |
last_exception | String | 最后一次遇到的异常信息。 |
select * from system.ha_replicas where table = 'test_table' and database = 'test'
Row 1: ────── type: clone_part lsn: 1001 create_time: 2025-06-10 10:00:00 source_replica: 192.18.x.x new_part_name: all_1_1_0 parts_to_merge: [] total_rows: 0 total_size: 0 is_currently_executing: 0 num_tries: 1 first_attempt_time: 2025-06-10 10:00:01 last_attempt_time: 2025-06-10 10:00:01 last_exception_time: 0000-00-00 00:00:00 last_exception: