前期准备

安装包下载：http://archive.apache.org/dist/flink/flink-1.10.2/

独立部署模式搭建

解压

[root@master ~]# tar -zxvf /data/flink-1.10.2 -C /usr/local/src/
[root@master ~]# mv /usr/local/src/flink-1.10.2 /usr/local/src/flink

配置环境变量

[root@master ~]# vi /etc/profile
  export FLINK_HOME=/usr/local/src/flink
  export PATH=$PATH:$FLINK_HOME/bin
[root@master ~]# source /etc/profile

集群架构

修改配置文件

[root@master ~]# vi /usr/local/src/flink/conf/flink-conf.yaml
  # （修改）指定主节点ip地址
  jobmanager.rpc.address: master

[root@master ~]# vi /usr/local/src/flink/conf/workers
  # （修改）指定从节点
  slave1 
  slave2

[root@master ~]# vi /usr/local/src/flink/conf/masters 
  # 改成主节点master
  master:8081

分发

[root@master ~]# scp -r /usr/local/src/flink slave1:/usr/local/src/
[root@master ~]# scp -r /usr/local/src/flink slave2:/usr/local/src/

启动(停止)集群

Flink集群的命令都在 bin 目录下，所有主从架构的集群都是在主节点操作命令

# 启动
[root@master ~]# start-cluster.sh
# 停止
[root@master ~]# stop-cluster.sh

提交作业(job)

[root@master ~]# flink run -c com.test.WordCount /data/flink-1.0.jar 

com.test.WordCount -- 主类名
/data/flink-1.0.jar -- jar包路径

访问Flink web界面

http://master节点ip:8081