一、Local模式
1.先上传Flink安装包到software目录下
2.解压到app目录下
tar -zxvf flink-1.9.1-bin-scala_2.11.tgz -C ../apps
3.启动flink
flink安装目录下的bin目录下
./start-cluster.sh
web端访问node-01:8081
切换到老版本界面：
4.关闭服务：
./stop-cluster.sh
5.测试在Local模式提交flink程序
使用官网提供的默认案例SocketWindowWordCount来统计从socket流中读取到的文本来进行单词计数
启动nc服务
nc -lk 9999 --端口号自定义为9999
提交jar包，用到flink安装目录下的bin目录下的flink,不过后面要加上run
在flink的安装目录下：
bin/flink run \
/home/offcn/apps/flink/examples/streaming/SocketWindowWordCount.jar \
--host node-01 --port 9999
查看执行结果：
Standalone Cluster 模式
1.修改配置文件
/home/offcn/apps/flink/conf
vim flink-conf.yaml --编辑flink-conf.yaml文件
/home/offcn/apps/flink/conf
vim slaves --编辑slaves文件
把localhost改为自己主机名
2.启动flink服务：
/home/offcn/apps/flink/bin 目录下
./start-cluster.sh --命令来启动集群
web端访问node-01：8081
Standalone HA
防止主节点单点故障
1.修改配置文件
/home/offcn/apps/flink/conf 目录下
vim flink-conf.yaml --编辑flink-conf.yaml文件
1.释放zookeeper这行配置
2.设置高可用模式文件存储位置
high-availability.storageDir: hdfs://node-01:8020/flink/ha/
3.重新设置zookeeper的位置
high-availability.zookeeper.quorum: node-01:2181,node-02:2181,node-03:2181
4. #开启HA，使用文件系统作为快照存储
state.backend: filesystem
5.存储JobManager的元数据到HDFS
6.修改conf/master 配置文件
设置集群中有两台机器可能成为主节点机器
node-01:8081
node-02:8082
7.修改第二台机器上的配置文件
到node02中将JobManager设置为自己节点的名称
配置完了
开启集群
/home/offcn/apps/flink/bin目录下
./start-cluster.sh --启动flink集群
web端访问node-01:8081,访问不到页面。服务没有启动起来
flink1.8之后不在支持hadoop的编译了
可以查看日志
解决方案：
1.将flink-shaded-hadoop-2-uber-2.7.5-9.0.jar放到安装目录下的lib目录里解决此问题。
2.分别分发到node-02,node-03两台机器上
scp -r flink-shaded-hadoop-2-uber-2.7.5-9.0.jar node-02:$PWD
scp -r flink-shaded-hadoop-2-uber-2.7.5-9.0.jar node-02:$PWD
再次启动集群：多了一下两个进程
StandaloneSessionClusterEntrypoint
TaskManagerRunner
