上文《实时流存储fluss学习系列(二)fluss安装部署》介绍了fluss快速开始,这里记录下官方介绍的部署教程。
一、下载fluss
在fluss官网下载最新版本的fluss即可,确保选择与您的 Java 版本匹配的Fluss 包。下载最新版本后,将其解压缩:
tar -xzf fluss-0.5.0-bin.tgz cd fluss-0.5.0/
二、启动本地Fluss
通过运行以下命令启动 Fluss 本地集群:
./bin/local-cluster.sh start
此后,Fluss本地集群就启动了。
Fluss 本地集群启动后,就可以使用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' );
当看到提示成功之后,就可以进行创建表,插入数据,查询数据等操作了。
还没有评论,来说两句吧...