单机安装

前提:jdk1.8
下载:https://flink.apache.org/downloads.html
目前的最新版本1.9.1,注意选择你的scala版本
下载以后上传到虚拟机中,解压:tar -zxvf flink-1.9.1-bin-scala_2.11.tgz
cd flink-1.9.1
bin/start-cluster.sh

有上面两个进程,说明已经安装成功
http://master:8081 进入webUI界面

停止:bin/stop-cluster.sh

分布式安装

进入flink的安装目录
vi conf/flink-conf.yaml
修改 jobmanager.rpc.address: master
vi conf/slaves
改为:slave1 slave2 注意换行

拷贝到slave1和slave2中去
scp -r flink-1.9.1 [email protected]:~/bigdata/
scp -r flink-1.9.1 [email protected]:~/bigdata/

配置环境变量:
export FLINK_HOME=~/bigdata/flink-1.9.0
在path后追加:$FLINK_HOME/bin
source .bash_profile

启动:
start-cluster.sh