基础环境配置

下载安装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查看是否有如下页面：