[转帖]clickhouse使用clickhouse-keeper代替zookeeper

clickhouse,使用,keeper,代替,zookeeper · 浏览次数 : 0

小编点评

**1. 卸载yum remove -y clickhouse-client.noarch clickhouse-common-static.x86_64 clickhouse-common-static-dbg.x86_64 clickhouse-server.noarch** **2. 下载安装yum install -y clickhouse-server-22.8.4.7-1.x86_64 clickhouse-client-22.8.4.7-1.x86_64 clickhouse-common-static-22.8.4.7-1.x86_64** **3. 迁移zk的元数据到 clickhouse-keeper** **4. 启动clickhouse-keeper** **5. 验证是否clickhouse-keeper是否正常运行** **6. 验证clickhouse是否正常运行连接客户端,创建一张分布式表,查看数据是否能正常操作分布式表(CRUD)** **7. 再次重启clickhouse** **8. 生成content时带简单的排版**

正文

目录

异常现象:

1. clickhouse的异常日志     

2. 追踪对应节点的zookeeper日志

使用clickhouse-keeper代替 zookeeper的步骤:

1: 准备 clickhouse-keeper的配置文件

1.1- 设置通信地址,以便对外通信

1.2-  在config.xml中的 zookeeper配置 clickhouse-keeper的地址,keeper的属性, 端口,存放地址等。 

a. 检查端口是否被占用

 b. 设置 clickhouse-keeper的地址,每个节点内容一致

c. 设置clickhouse-keeper的server_id 和clickhouse-server通信端口 9444

2:备份 clickhouse-server的配置文件和数据,以及zookeeper的元数据。(预防升级失败需要回滚)

a.  clickhouse的数据,在config.xml

b.  zookeeper的数据:  在zoo.cfg,数据目录。

3:升级clickhouse。( 包含了clickhouse-server,clickhouse-common, clickhouse-keeper和clickhouse-keeper-converter )

4: 迁移zk的元数据到 clickhouse-keeper  

a- 停止所有的zk 节点。    

b- 建议 启停zk的leader,以便强制 复制一份 一致性的快照。

  c- 运行  clickhouse-keeper-converter , 生成snapshot   

    e- 单独启动clickhouse-keeper

5- 重启 clickhouse    

6- 验证是否clickhouse-keeper是否正常运行   

7- 验证clickhouse是否正常运行

在重启clickhouse时可能遇到认证问题


背景:clickhouse分布式表使用zookeeper作为元数据的存储,客户端每次读写分布式表都会读写zookeeper。 zookeeper是个小型的日志文件系统,在大范围读写时会进入只读模式

clickhouse官方为了解决这个,自己开发了clickhouse-keeper来代替。在21.8版本开始引入,21.12 featrue开发完毕,22.05不依赖系统库。

据官网自己说,目前22.5版的写性能和zookeeper相当,读的性能比zookeeper好。

异常现象:

1. clickhouse的异常日志
    

可以看到说socket和zookeeer连接不上 xxx.xxx.xxx.xxx:2181)

  1. 2022.04.01 17:11:01.452465 [ 428517 ] {} <Error> void Coordination::ZooKeeper::sendThread(): Code: 210, e.displayText() = DB::NetException: I/O error: 23: Can't create epoll queue, while writing to socket (20.20.20.34:2181), Stack trace (when copying this message, always include the lines below):
  2. 1. DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int, bool) @ 0x8f9b87a in /usr/lib/debug/.build-id/b1/6d23354750e4d6ff9887c2b4f856f045d62da0.debug
  3. 2. DB::WriteBufferFromPocoSocket::nextImpl() @ 0x100764a0 in /usr/lib/debug/.build-id/b1/6d23354750e4d6ff9887c2b4f856f045d62da0.debug

2. 追踪对应节点的zookeeper日志

看到 zookeeper进入了只读模式(r-o mode)

  1. 2022-04-01 07:21:14,189 [myid:3] - INFO [PurgeTask:FileTxnSnapLog@124] - zookeeper.snapshot.trust.empty : false
  2. 2022-04-01 07:21:14,191 [myid:3] - INFO [PurgeTask:DatadirCleanupManager$PurgeTask@145] - Purge task completed.
  3. 2022-04-01 17:07:55,961 [myid:3] - INFO [SessionTracker:ZooKeeperServer@628] - Expiring session 0x31056da7a8a0000, timeout of 30000ms exceeded
  4. 2022-04-01 17:07:55,962 [myid:3] - INFO [RequestThrottler:QuorumZooKeeperServer@163] - Submitting global closeSession request for session 0x31056da7a8a0000
  5. 2022-04-01 17:10:23,523 [myid:3] - WARN [NIOWorkerThread-75:ZooKeeperServer@1411] - Connection request from old client /20.20.20.46:62879; will be dropped if server is in r-o mode
  6. 2022-04-01 17:10:23,534 [myid:3] - INFO [CommitProcessor:3:LeaderSessionTracker@104] - Committing global session 0x31056da7a8a0001
  7. 2022-04-01 17:11:01,453 [myid:3] - WARN [NIOWorkerThread-20:NIOServerCnxn@371] - Unexpected exception
  8. EndOfStreamException: Unable to read additional data from client, it probably closed the socket: address = /20.20.20.46:62879, session = 0x31056da7a8a0001
  9. at org.apache.zookeeper.server.NIOServerCnxn.handleFailedRead(NIOServerCnxn.java:170)
  10. at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:333)
  11. at org.apache.zookeeper.server.NIOServerCnxnFactory$IOWorkRequest.doWork(NIOServerCnxnFactory.java:508)
  12. at org.apache.zookeeper.server.WorkerService$ScheduledWorkRequest.run(WorkerService.java:154)
  13. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  14. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  15. at java.lang.Thread.run(Thread.java:748)

使用clickhouse-keeper代替 zookeeper的步骤:

1- 准备 clickhouse-keeper的配置文件 (config.xml)
2- 备份 clickhouse-server的配置文件和数据,以及zookeeper的元数据
3- 下载 clickhouse-keeper-converter (集成在clickhouse中了)

4- 迁移以前zookeeper元数据到clickhouse-keeper

    a. 停止所有zk节点
    b. 找到zk leader节点
    c. 重启zk leader节点,并再次停止(这一步是为了让leader节点生成一份snapshot)
    d. 运行clickhouse-keeper-converter,生成keeper的snapshot文件
    e. 启动keeper, 使其加载上一步中的snapshot

5- 重启clickhouse-server


1: 准备 clickhouse-keeper的配置文件

keeper在clickhousenode上的配置    config.xml

1.1- 设置通信地址,以便对外通信

<listen_host>0.0.0.0</listen_host>

1.2-  在config.xml中的 zookeeper配置 clickhouse-keeper的地址,keeper的属性, 端口,存放地址等。 

a. 检查端口是否被占用

 假设keeper的端口是9181,与server通信接口为9444

  1. netstat -anp | grep 9181 
  2. netstat -anp | grep 9444

 b. 设置 clickhouse-keeper的地址,每个节点内容一致

  1. <zookeeper>
  2.         <node>
  3.             <host>clickhouse-node01</host>
  4.             <port>9181</port>
  5.         </node>
  6.         <node>
  7.             <host>clickhouse-node02</host>
  8.             <port>9181</port>
  9.         </node>
  10.         <node>
  11.             <host>clickhouse-node03</host>
  12.             <port>9181</port>
  13.         </node>
  14.     </zookeeper>

c. 设置clickhouse-keeper的server_id 和clickhouse-server通信端口 9444

每个节点的server_id要确保唯一,不能和其他节点重复 , keeper_server中的server_id是要和配置raft协议集群时命名的一致。

例如:

在 clickhouse-node01上的配置, <server_id>1</server_id>

在clickhouse_node02上的配置,  <server_id>2</server_id>

  1. <keeper_server>
  2.     <tcp_port>9181</tcp_port>
  3.     <server_id>1</server_id>
  4.     <log_storage_path>/var/lib/clickhouse/coordination/log</log_storage_path>
  5.     <snapshot_storage_path>/var/lib/clickhouse/coordination/snapshots</snapshot_storage_path>
  6.     <coordination_settings>
  7.         <operation_timeout_ms>10000</operation_timeout_ms>
  8.         <session_timeout_ms>30000</session_timeout_ms>
  9.         <raft_logs_level>warning</raft_logs_level>
  10.     </coordination_settings>
  11.     <raft_configuration>
  12.         <server>
  13.             <id>1</id>
  14.             <hostname>clickhouse-node01</hostname>
  15.             <port>9444</port>
  16.         </server>
  17.         <server>
  18.             <id>2</id>
  19.             <hostname>clickhouse-node02</hostname>
  20.             <port>9444</port>
  21.         </server>
  22.         <server>
  23.             <id>3</id>
  24.             <hostname>clickhouse-node03</hostname>
  25.             <port>9444</port>
  26.         </server>
  27.     </raft_configuration>
  28. </keeper_server>

2:备份 clickhouse-server的配置文件和数据,以及zookeeper的元数据。(预防升级失败需要回滚)

a.  clickhouse的数据,在config.xml

<path>/data/1/clickhouse</path>

b.  zookeeper的数据:  在zoo.cfg,数据目录。


     dataDir=/data/1/zookeeper/data    (存储snap数据)
     dataLogDir=/data/1/zookeeper/logs   (存储 transation命令)

3:升级clickhouse。( 包含了clickhouse-server,clickhouse-common, clickhouse-keeper和clickhouse-keeper-converter )

      以先卸载,再安装的升级方法为例

  1. ## 卸载
  2. yum remove -y clickhouse-client.noarch clickhouse-common-static.x86_64 clickhouse-common-static-dbg.x86_64 clickhouse-server.noarch
  3. ## 下载安装
  4. yum install -y clickhouse-server-22.8.4.7-1.x86_64 clickhouse-client-22.8.4.7-1.x86_64 clickhouse-common-static-22.8.4.7-1.x86_64  clickhouse-common-static-dbg-22.8.4.7-1.x86_64

4: 迁移zk的元数据到 clickhouse-keeper
  

a- 停止所有的zk 节点。    

       在所有的zk节点上 执行

 /usr/local/zookeeper/bin/zkServer.sh stop


b- 建议 启停zk的leader,以便强制 复制一份 一致性的快照。

       查找leader节点, 在所有的节点上执行

/usr/local/zookeeper/bin/zkServer.sh stop


      在leader节点上 启停zookeeper    

  1. /usr/local/zookeeper/bin/zkServer.sh start
  2. /usr/local/zookeeper/bin/zkServer.sh stop


  c- 运行  clickhouse-keeper-converter , 生成snapshot
   

clickhouse-keeper-converter --zookeeper-logs-dir /data/1/zookeeper/logs/version-2 --zookeeper-snapshots-dir /data/1/zookeeper/data/version-2 --output-dir /var/lib/clickhouse/coordination/snapshots

    e- 单独启动clickhouse-keeper

如果server和keeper是安装在同一个节点,这步可以省略

  1. sudo -su clickhouse
  2. clickhouse-keeper --config  /etc/clickhouse-server/config.xml

5- 重启 clickhouse 
   

  1. /usr/bin/clickhouse-server stop
  2. /usr/bin/clickhouse-server start --config=/etc/clickhouse-server/config.xml


6- 验证是否clickhouse-keeper是否正常运行   

 echo ruok | nc localhost 9181; echo

期望看到:imok    


7- 验证clickhouse是否正常运行

连接客户端,创建一张分布式表,查看数据是否能正常操作分布式表(CRUD)。 

 select * from system.clusters;



在重启clickhouse时可能遇到认证问题

1- 异常log

<Error> CertificateReloader: Cannot obtain modification time for certificate file /etc/clickhouse-server/server.crt, skipping update. errno: 2, strerror: No such file or directory

解决方法:在所有的clickhouse-server节点上执行

openssl req -subj "/CN=localhost" -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout /etc/clickhouse-server/server.key -out /etc/clickhouse-server/server.crt

2- 异常log

Error opening Diffie-Hellman parameters file /etc/clickhouse-server/dhparam.pem

解决方法:  在所有的clickhouse-server节点上执行

openssl dhparam -out /etc/clickhouse-server/dhparam.pem 4096

 


clickhouse既然已经支持多zk集群,是否可以让ck同时访问zk集群和keeper集群?

答: 不可以,官网明确说了

 


参考文档:

ClickHouse Keeper | ClickHouse Docs
Configuring ClickHouse Keeper (clickhouse-keeper) | ClickHouse Docs
 
 
 


   
   

文章知识点与官方知识档案匹配,可进一步学习相关知识
云原生入门技能树首页概览14382 人正在系统学习中

与[转帖]clickhouse使用clickhouse-keeper代替zookeeper相似的内容:

[转帖]clickhouse使用clickhouse-keeper代替zookeeper

目录 异常现象: 1. clickhouse的异常日志 2. 追踪对应节点的zookeeper日志 使用clickhouse-keeper代替 zookeeper的步骤: 1: 准备 clickhouse-keeper的配置文件 1.1- 设置通信地址,以便对外通信 1.2- 在config.xml

[转帖]Clickhouse单机及集群部署详解

https://www.cnblogs.com/ya-qiang/p/13540016.html 一、ClickHouse简介 ClickHouse是近年来备受关注的开源列式数据库,主要用于数据分析(OLAP)领域。目前国内社区火热,各个大厂纷纷跟进大规模使用: 今日头条 内部用ClickHouse

[转帖]tgz 安装clickhouse

一、什么是clickhouse ClickHouse是开源的列式存储数据库(DBMS),主要用于在线处理查询(OLAP),能够使用SQL查询实时生成数据分析报告。 下面介绍下安装clickhouse。 二、安装前的准备1、Centos取消打开文件数限制在/etc/security/limits.co

[转帖]clickHouse单机模式安装部署(RPM安装)

关于版本和系统的选择 操作系统:Centos-7 ClickHouse: rpm 在安装,20.x 安装前的准备 CentOS7 打开文件数限 在 /etc/security/limits.conf 这个文件的末尾加入一下内容: [hadoop@hadoop001 ~]$ sudo vim /etc

[转帖]clickhouse存储机制以及底层数据目录分布

https://www.cnblogs.com/MrYang-11-GetKnow/p/15818141.html#:~:text=%E6%AF%8F%E4%B8%80%E4%B8%AA%E6%95%B0%E6%8D%AE%E5%BA%93%E9%83%BD%E4%BC%9A%E5%9C%A8cli

[转帖]谈谈ClickHouse性能情况以及相关优化

https://zhuanlan.zhihu.com/p/349105024 ClickHouse性能情况 主要分为4个方面 1、单个查询吞吐量 场景一: 如果数据被放置在page cache中,则一个不太复杂的查询在单个服务器上大约能够以2-10GB/s(未压缩)的速度进行处理(对于简单的查询,速

[转帖]什么是ClickHouse?

什么是ClickHouse? ClickHouse是一个用于联机分析(OLAP)的列式数据库管理系统(DBMS)。 在传统的行式数据库系统中,数据按如下顺序存储: RowWatchIDJavaEnableTitleGoodEventEventTime #0 89354350662 1 Investo

[转帖]一文快速入门 ClickHouse

https://zhuanlan.zhihu.com/p/621480049 什么是clickhouse ClickHouse是一种OLAP类型的列式数据库管理系统,这里有两个概念:OLAP、列式数据库。这两个概念会在接下来做介绍,ClickHouse完美的实现了OLAP和列式数据库的优势,因此在大

[转帖]TiDB升级、TiFlash测试及对比ClickHouse

原创 NewSQL 作者:o烟雨潇潇o 时间:2020-05-13 11:53:16 4418 0 TiDB升级、TiFlash测试及对比ClickHouse --2020-05-13 刘春雷 1、汇总 1.1、需求 测试3.0.7 升级至4.0.0-rc 测试部署TiFlash 测试TiFlash

[转帖]ck的离线安装

下载 下载地址: https://repo.clickhouse.tech/tgz/stable/ 下载的包: clickhouse-common-static clickhouse-server clickhouse-client 单机安装 tar -zxvf clickhouse-common-