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
出现下图即启动成功:
启动FinkSQL:
[root@localhost bin]# ./sql-client.sh
出现:小松鼠图案即开启成功
停止服务:
[root@localhost bin]# ./stop-cluster.sh
出现下图即停止成功: