前期准备

安装包下载：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]# start-cluster.sh

提交作业(job)

[root@master ~]# flink run $FLINK_HOME/examples/streaming/WordCount.jar

查看日志(结果)

[root@master ~]# tail $FLINK_HOME/log/flink-*-taskexecutor-*.out

监视集群的状态和正在运行的作业

http://localhost:8081/#/overview

停止集群

[root@master ~]# stop-cluster.sh