基础环境配置
下载安装flink
下载安装flink安装包文件,并解压:
tar -zxvf flink-1.7.1-bin-hadoop27-scala_2.11.tgz -C ./
JDK安装
下载JDK,解压:
tar -zxvf jdk-8u181-linux-x64.tar.gz -C ./
设置环境变量:
vim ~/.bash_profile
export JAVA_HOME=/home/jdk1.8.0_181
export PATH=$JAVA_HOME/bin:$PATH
source ~/.bash_profile
验证java是否配置成功:
java -version
安装部署
standalone方式部署
standalone的方式不需要修改配置文件内容,直接执行如下命令启动即可:
flink/bin/start-cluster.sh
打印日志如下:
Starting cluster.
Starting standalonesession daemon on host flinkMaster.
Starting taskexecutor daemon on host flinkMaster.
集群方式部署
填写配置文件
集群方式需要修改配置文件内容,打开flink/conf目录下的flink-conf.yaml配置文件,需要配置以下变量值:
-- 可以理解为spark的driver
jobmanager.rpc.address: localhost
jobmanager.rpc.port: 6123
这个修改为主节点的主机名。
打开flink/conf目录下的masters文件,修改主机名。
打开flink/conf目录下的slaves文件,填写从节点的主机名。
然后将该flink目录分发到从节点后,启动如下命令即可:
flink/bin/start-cluster.sh
查看前端页面
浏览器打开端口8081查看是否有如下页面: