Dinky 连接 FlinkCli 控制台

 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

参数解释：

-p 8888:8888    dinky默认8888端口

-v /data/flink:/opt/dinky/customJar/    docker版dinky为我们预留了自定义依赖入口，只需要把我们刚刚建立的目录映射到容器内/opt/dinky/customJar/路径即可

访问http://localhost:8888/ 即可看见dinky页面

默认账号：admin

默认密码：dinky123!@#

四、注册集群

登录Dinky之后，依次点击注册中心，集群实例，新建。

集群名称自定义，类型选择 Standalone，JobManager 地址填写我们刚刚启动的 Flink 地址 localhost:8081 ，然后点击保存。

保存成功后，如图所示，显示状态正常即可，如果状态异常，则表示集群地址填写有误，请检查。

五、连接 SQL CLI

回到数据开发页面，点击左侧 SQL CLI 按钮，在弹出页面选择我们刚刚添加的集群。

点击连接。铛铛铛！连接成功！然后我们就可以在 cli 内尽情玩耍啦。

DDL：

查询数据：