温州专业手机网站制作哪家便宜,wordpress简体中文版,做网站如何推广,广告设计自学教程现象
数据从集群中一个节点写入之后#xff0c;其他两个节点无法及时查询到数据#xff0c;等了几分钟。因为我们ck集群是读写分离架构#xff0c;也就是一个节点写数据#xff0c;其他节点供读取。
排查思路
从业务得知#xff0c;数据更新时间点为#xff1a;11:30。…现象
数据从集群中一个节点写入之后其他两个节点无法及时查询到数据等了几分钟。因为我们ck集群是读写分离架构也就是一个节点写数据其他节点供读取。
排查思路
从业务得知数据更新时间点为11:30。查看clickhouse-server.log日志。
Clickhouse 节点1 被写入日志 2023.10.11 11:30:01.435628 [ 14098 ] {} dws_stock.trade_kline_60_min (ff4239f7-1eb5-40f3-8f18-bdb0d525886d) (MergerMutator): Selected 6 parts from 20231011_0_2_1 to 20231011_7_7_0
2023.10.11 11:30:03.335051 [ 69289 ] {e9e7f8b6-3978-4593-a750-ebc6c5c2e231} executeQuery: (from [::ffff:192.168.122.11]:50788, user: p_realtime_writer) insert into kline_1h (data_date,instr,bar_time,open,high,low,close,vwap,volume,amount,adj_af_open,adj_af_high,adj_af_low,adj_af_close,adj_af_vwap,adj_af_volume,adj_af_amount,up_limit_price,low_limit_price) FORMAT RowBinary (stage: Complete)
2023.10.11 11:30:03.342347 [ 69289 ] {e9e7f8b6-3978-4593-a750-ebc6c5c2e231} dws_stock.kline_1h (0cb13f31-1c20-433a-af76-758a7da5bb65) (Replicated OutputStream): Wrote block with ID ‘20231011_18249948133543406312_10292782376228156948’, 5067 rows
可以看到该节点在2023.10.11 11:30:03.342347的时候写入了5067行数据对应的分区应该为上述日志所打印的20231011_7_7_0。 我们知道ck数据的更新操作是由zk负责复制日志其他节点读取日志然后从对应的节点进行更新的。而insert操作并不属于mutation操作mutation操作主要包括alter、alter update、delete。insert操作将记录在Entry Log内对应在zk的节点为…/log。具体路径将会在下文中体现。 所以我们查看与该表相关的EntryLog
select name,value from system.zookeeper where path/clickhouse/tables/{cluster}/库名/表名/1/log/ limit 10;
然后我们发现和20231011_7_7_0相关的Log为log-0000030818上图没有。图上的get操作是数据分区下载。
节点22023.10.11 11:35:58才取到数据 2023.10.11 11:30:03.386868 [ 53605 ] {} dws_stock.kline_1h (ReplicatedMergeTreeQueue): Pulling 1 entries to queue: log-0000030818 - log-0000030818
2023.10.11 11:30:03.398940 [ 53605 ] {} dws_stock.kline_1h (ReplicatedMergeTreeQueue): Pulled 1 entries to queue.
2023.10.11 11:30:03.398940 已经把Log拿到了但是2023.10.11 11:35:58.325150才开始下载数据也就是Fetch操作这里注意Ck副本节点会直接去主副本节点下载数据而不是从zk下载。zk不存储ck任何数据除了日志外。并且数据几十毫秒就下完了。 2023.10.11 11:35:58.325150 [ 53513 ] {} dws_stock.kline_1h (0cb13f31-1c20-433a-af76-758a7da5bb65): Fetching part 20231011_7_7_0 from /clickhouse/tables/ckcluster/dws_stock/kline_1h/1/replicas/192.168.122.29
2023.10.11 11:35:58.336188 [ 53513 ] {} dws_stock.kline_1h (0cb13f31-1c20-433a-af76-758a7da5bb65): Fetched part 20231011_7_7_0 from /clickhouse/tables/ckcluster/dws_stock/kline_1h/1/replicas/192.168.122.29
同样我们看到节点32023.10.11 11:48:00.179239 才取到数据
2023.10.11 11:30:03.392957 [ 38863 ] {} dws_stock.kline_1h (ReplicatedMergeTreeQueue): Pulling 1 entries to queue: log-0000030818 - log-0000030818 2023.10.11 11:30:03.498140 [ 38863 ] {} dws_stock.kline_1h (ReplicatedMergeTreeQueue): Pulled 1 entries to queue.
2023.10.11 11:48:00.179239 [ 38708 ] {} dws_stock.kline_1h (0cb13f31-1c20-433a-af76-758a7da5bb65): Fetched part 20231011_7_7_0 from /clickhouse/tables/ckcluster/dws_stock/kline_1h/1/replicas/192.168.122.29 2023.10.11 11:48:00.163862 [ 38708 ] {} dws_stock.kline_1h (0cb13f31-1c20-433a-af76-758a7da5bb65): Fetching part 20231011_7_7_0 from /clickhouse/tables/ckcluster/dws_stock/kline_1h/1/replicas/192.168.122.29
那么这两个ck节点在拿到Entry Log之后为什么等了几分钟甚至10几分钟才开始获取数据 这里百思不得其姐推测和集群负载有关系。查看当时ck集群的负载
联系了业务得知但是这段时间内在做一个应用的压力测试。(
另外ck的写节点在这段时间内一直有大量的 Too many parts (302) 异常一直持续了8分钟。
2023.10.11 11:37:23.404245 [ 70328 ] {6df768b2-6ee3-423c-9f3d-ffde4ff37584} Error DynamicQueryHandler: Code: 252. DB::Exception: Too many parts (302). Merges are processing significantly slower than inserts. (TOO_MANY_PARTS), Stack trace (when copying this message, always include the lines below)
所以基本可以断定是因为但是ck节点负载太高导致的副本之间的数据同步延迟因为ck是异步复制对于实时性要求很高的业务可选择读写使用同一个节点规避这个问题。
