在使用docker部署之前,先要确保服务器的配置至少为4H16G的配置,并且安装了docker和docker-compose命令。版本要求如下:
Docker 版本:20.10 或更高版本。
docker-compose版本:20.1或更高版本
具体的安装步骤如下:
1、创建共享的 tmpfs 卷:
docker volume create shared-tmpfs
2、在docker中创建隔离桥接网络
docker network create fluss-demo
3、以守护进程模式启动 Zookeeper。这是单节点 zookeeper 设置。Zookeeper 是 Fluss 的中央元数据存储,应设置复制以供生产使用。
docker run \ --name zookeeper \ --network=fluss-demo \ --restart always \ -p 2181:2181 \ -d zookeeper:3.9.2
4、以守护进程的形式启动Fluss CoordinatorServer并连接到Zookeeper。
docker run \ --name coordinator-server \ --network=fluss-demo \ --env FLUSS_PROPERTIES="zookeeper.address: zookeeper:2181 coordinator.host: coordinator-server" \ -p 9123:9123 \ -d fluss/fluss:0.5.0 coordinatorServer
5、在生产环境中,需要启动多个Fluss TabletServer节点,这里我们在daemon中启动3个Fluss TabletServer节点,并连接Zookeeper,
5.1、启动tablet-server-0
docker run \ --name tablet-server-0 \ --network=fluss-demo \ --env FLUSS_PROPERTIES="zookeeper.address: zookeeper:2181 tablet-server.host: tablet-server-0 tablet-server.id: 0 tablet-server.port: 9124 data.dir: /tmp/fluss/data/tablet-server-0 remote.data.dir: /tmp/fluss/remote-data" \ -p 9124:9124 \ --volume shared-tmpfs:/tmp/fluss \ -d fluss/fluss:0.5.0 tabletServer
5.2、启动 tablet-server-1
docker run \ --name tablet-server-1 \ --network=fluss-demo \ --env FLUSS_PROPERTIES="zookeeper.address: zookeeper:2181 tablet-server.host: tablet-server-1 tablet-server.id: 1 tablet-server.port: 9125 data.dir: /tmp/fluss/data/tablet-server-1 remote.data.dir: /tmp/fluss/remote-data" \ -p 9125:9125 \ --volume shared-tmpfs:/tmp/fluss \ -d fluss/fluss:0.5.0 tabletServer
5.3、启动 tablet-server-2
docker run \ --name tablet-server-2 \ --network=fluss-demo \ --env FLUSS_PROPERTIES="zookeeper.address: zookeeper:2181 tablet-server.host: tablet-server-2 tablet-server.id: 2 tablet-server.port: 9126 data.dir: /tmp/fluss/data/tablet-server-2 remote.data.dir: /tmp/fluss/remote-data" \ -p 9126:9126 \ --volume shared-tmpfs:/tmp/fluss \ -d fluss/fluss:0.5.0 tabletServer
6、运行以下命令检查 Fluss 集群状态:
docker container ls -a
启动后,就可以使用Fluss Client(目前仅支持 Flink Sql Client)与 Fluss 交互。在独立的flink集群种,把fluss的依赖jar添加到flink集群种,然后重启flink集群。
依赖下载地址:
https://alibaba.github.io/fluss-docs/downloads/
然后在flink集群种启动flink sql客户端,直接创建fluss的多数据源目录
CREATE CATALOG fluss_catalog WITH ( 'type'='fluss', 'bootstrap.servers' = 'localhost:9123' );
当看到提示成功之后,就可以进行创建表,插入数据,查询数据等操作了。
还没有评论,来说两句吧...