ClickHouse副本插入行为控制及分片副本数据均衡问题咨询

数据老陈

2026-8-5

ClickHouse 副本数据同步与查询问题解决方案

核心认知纠正

首先明确：ReplicatedMergeTree 的副本是数据冗余备份机制，同一个分片的所有副本应存储完全相同的数据，而非分摊存储数据。你期望“分片1每个副本约20万条”是对副本作用的误解，正确目标应为：分片1的所有副本都存储分片1的全部数据（约55万条），分片2的所有副本都存储分片2的全部数据（约55万条）。

问题分析

副本数据分布不均：开启 internal_replication = true 后，Distributed 表只会将数据发送到每个分片的单个副本，再由 ReplicatedMergeTree 自身同步到同分片其他副本。你当前的副本数据差异，说明同步机制未正常工作。
查询计数不符：ClickHouse 查询 Distributed 表时，默认从每个分片选择一个健康副本读取数据，因此仅统计了分片1-副本1（53万）和分片2-副本1（55万）的总和，其他副本的零散未同步数据未被读取。

解决方案

一、修复副本同步问题（解决数据分布不均）

验证 ZooKeeper 配置一致性
确保所有副本的 zookeeper 配置完全一致，能连接到同一 ZooKeeper 集群，且 ReplicatedMergeTree 表的 ZooKeeper 路径定义正确：

CREATE TABLE your_db.your_table ON CLUSTER your_cluster (
    -- 表结构定义
) ENGINE = ReplicatedMergeTree(
    '/clickhouse/tables/{shard}/your_table', -- 同分片所有副本共用此路径前缀
    '{replica}' -- 每个副本的唯一名称
)
ORDER BY your_order_key;

检查副本同步状态
在每个副本节点执行以下语句，查看同步状态：
```
SELECT 
    database, table, replica_name, is_leader, is_syncing, 
    last_queue_update, future_parts, error 
FROM system.replicas 
WHERE database = 'your_db' AND table = 'your_table';
```
- 重点关注 is_syncing（是否在同步）、future_parts（待同步分区数）、error（同步错误信息）字段，排查是否有连接故障或权限问题。
手动触发同步（若需）
对卡住的副本，可手动触发同步：
```
ALTER TABLE your_db.your_table ON CLUSTER your_cluster 
FETCH PARTITION ALL FROM '/clickhouse/tables/shard1/your_table/replica1';
```
替换路径为同分片已同步完成的副本路径，或直接重启对应节点的 ClickHouse 服务。

确认集群配置正确性
检查集群配置文件（如 config.xml 或 metrika.xml），确保每个分片包含所有对应副本，且 internal_replication 开启：

<cluster name="your_cluster">
    <shard>
        <internal_replication>true</internal_replication>
        <replica>
            <host>shard1-repl1</host>
            <port>9000</port>
        </replica>
        <replica>
            <host>shard1-repl2</host>
            <port>9000</port>
        </replica>
        <replica>
            <host>shard1-repl3</host>
            <port>9000</port>
        </replica>
    </shard>
    <shard>
        <internal_replication>true</internal_replication>
        <replica>
            <host>shard2-repl1</host>
            <port>9000</port>
        </replica>
        <replica>
            <host>shard2-repl2</host>
            <port>9000</port>
        </replica>
    </shard>
</cluster>

二、修复查询计数问题

当同分片所有副本数据同步完成后，查询 Distributed 表时，ClickHouse 会自动从每个分片选择健康副本读取数据，此时 count() 结果会返回正确的110万条。

若需利用同分片多个副本分摊查询压力（提高查询速度），可配置负载均衡策略：
在 config.xml 的 profiles 段添加：

<profiles>
    <default>
        <load_balancing>round_robin</load_balancing>
    </default>
</profiles>

可选值：random（随机选择）、round_robin（轮询）、nearest_hostname（就近选择），该配置会让查询在同分片副本间分摊压力，但每个查询仍仅从每个分片的单个副本读取数据，不会重复统计。

三、关于“数据均衡到每个副本”的正确实现

若想让数据分散到更多节点存储，应增加分片数量，而非副本数量。副本的核心作用是高可用（节点故障时自动切换）和查询负载分摊，而非数据分片存储。

内容的提问来源于stack exchange，提问作者huwng

ClickHouse副本插入行为控制及分片副本数据均衡问题咨询

核心认知纠正 #

问题分析 #

解决方案 #

一、修复副本同步问题（解决数据分布不均） #

二、修复查询计数问题 #