在Dinky中连接FlinkCli客户端进行SQL操作

大数据技能圈 2024-08-16

导读：本文介绍了 Dinky 实时计算平台如何连接 FlinkCli 控制台。

社区公告：

问题反馈、代码提交、文章投稿与社区贡献请移步 Github issue。

Github issue #66 登记企业或组织生产使用，可邀请至企业支持群，获取团队技术支持与其他企业用户的经验分享。

GitHub 地址

https://github.com/DataLinkDC/dinky

https://gitee.com/DataLinkDC/Dinky

欢迎大家为 Dinky 送上小星星~

一、部署Flink

为了简化教程，本次我们之间部署单机Flink版本，实际使用过程中可自行连接你自己的集群。

下载、解压、启动 Flink。

wget https://archive.apache.org/dist/flink/flink-1.17.2/flink-1.17.2-bin-scala_2.12.tgz
tar -zxvf flink-1.17.2-bin-scala_2.12.tgz
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 包。

flink-sql-client-1.17.2.jar
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