Flink版本:1.16
环境:Linux CentOS 7.0、jdk1.8
基础文件:flink-1.16.2-bin-scala_2.12.tgz、flink-connector-jdbc-3.0.0-1.16.jar、flink-sql-connector-mysql-cdc-2.3.0.jar
1. 在目录/home/flink下解压flink-1.16.2-bin-scala_2.12.tgz文件
tar -zxvf flink-1.16.2-bin-scala_2.12.tgz
2. 添加环境变量:
vim etc/profile
添加环境flink环境变量:
#FLINK_HOME
export FLINK_HOME=/home/flink-1.16.2
export PATH=$PATH:$FLINK_HOME/bin
环境变量及时生效:
source /etc/profile
3. 在目录/home/flink-1.16.2/conf下修改配置文件flink-conf.yaml:
只需要修改一个地方
rest.bind-address: 0.0.0.0 (默认是localhost)
4. 将jar包flink-connector-jdbc-3.0.0-1.16.jar、flink-sql-connector-mysql-cdc-2.3.0.jar放到 flinkcdc安装路径lib文件夹下
5. 到目录/home/flink-1.16.2/bin下运行:
开启Flink服务:
[root@localhost bin]# ./start-cluster.sh
出现下图即启动成功:
![](https://img-blog.csdnimg.cn/4f0dda043ab343fb8266c74faed5d08b.png)
启动FinkSQL:
[root@localhost bin]# ./sql-client.sh
出现:小松鼠图案即开启成功
![](https://img-blog.csdnimg.cn/918acaaca28c4c60837a03c744efbb6c.png)
![](https://img-blog.csdnimg.cn/755458a7568f42d5abf6a43aa1bf35a8.png)
停止服务:
[root@localhost bin]# ./stop-cluster.sh
出现下图即停止成功:
![](https://img-blog.csdnimg.cn/47c3e77392b9480cb7c0c6ff269bfa62.png)