什么是Dinky?
Dinky 是一个开箱即用的一站式实时计算平台,以 Apache Flink 为基础,连接 OLAP 和数据湖等众多框架,致力于流批一体和湖仓一体的建设与实践。
flink sql cli是flink 提供的一个sql执行工具,可以方便的进行sql预览,执行等操作
项目地址:https://github.com/DataLinkDC/dinky
如果觉得项目不错欢迎前去点下
Star
原文阅读:【巨人肩膀社区·专栏·分享】 Dinky手把手教程 - 连接Flink Sql Cli控制台
开始
部署flink
为了简化教程,本次我们之间部署单机Flink版本,实际使用过程中可自行连接你自己的集群
- 下载flink
wget https://archive.apache.org/dist/flink/flink-1.17.2/flink-1.17.2-bin-scala_2.12.tgz
- 解压flink
tar -zxvf flink-1.17.2-bin-scala_2.12.tgz
- 启动flink
cd flink-1.17.2
./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host DESKTOP-S65S3F5.
Starting taskexecutor daemon on host DESKTOP-S65S3F5.
准备依赖
连接flink sql cli需要两个jar包
-rw-r--r-- 1 root root 931K Aug 7 20:43 flink-sql-client-1.17.2.jar
-rw-r--r-- 1 root root 206K Aug 7 20:43 flink-sql-gateway-1.17.2.jar
他们在flink安装目录 opt文件夹下面,属于可选组件,所以dinky docker内默认没有集成,我们需要放进去
执行以下命令建立目录并放置我们的依赖
cd ..
mkdir /data
mkdir /data/flink
cp flink-1.17.2/opt/flink-sql-client-1.17.2.jar /data/flink
cp flink-1.17.2/opt/flink-sql-gateway-1.17.2.jar /data/flink
部署Dinky
dinky 1.1.0发布了docker包,我们可以通过docker 快速部署
# 下载镜像
docker pull dinkydocker/dinky-standalone-server:1.1.0-flink1.17
# 启动服务
docker run --restart=always -p 8888:8888 \
--name dinky \
-v /data/flink:/opt/dinky/customJar/ \
dinkydocker/dinky-standalone-server:1.1.0-flink1.17
参数解释
-p 8888:8888
dinky默认8888端口
-v /data/flink:/opt/dinky/customJar/
docker版dinky为我们预留了自定义依赖入口,只需要把我们刚刚建立的目录映射到容器内/opt/dinky/customJar/路径即可
访问http://localhost:8888/ 即可看见dinky页面
默认账号:admin
默认密码:dinky123!@#
image.png
注册集群
登录Dinky之后,依次点击
注册中心
,
集群实例
,
新建
集群名称随便填,类型选择Standalone,JobManager地址填写我们刚刚启动的Flink地址
localhost:8081
,然后点击保存。
image.png
保存成功后,如图所示,显示状态正常即可,如果状态异常,则表示集群地址填写有误,请检查
image.png
连接SQL CLI
回到数据开发页面,点击左侧SQL CLI按钮,在弹出页面选择我们刚刚添加的集群
image.png
点击连接
铛铛铛!连接成功!然后我们就可以在cli内尽情玩耍啦。
image.png
DDL
image.png
查询数据
版权归原作者 atbigapp.com 所有, 如有侵权,请联系我们删除。