Flink系统架构中包含了两个角色，分别是JobManager和TaskManager，是一个典型的Master-Slave架构。JobManager相当于是Master，TaskManager相当于是Slave

1. Standalone 部署安装

https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.
11.tgz

1.1 修改flink-conf.yaml配置文件

#JobManager地址
jobmanager.rpc.address: node01
 
# JobManagerRPC通信端口
jobmanager.rpc.port: 6123
 
# JobManager所能使用的堆内存大小
jobmanager.heap.size: 1024m
 
#  TaskManager所能使用的堆内存大小
taskmanager.heap.size: 1024m
 
# TaskManager管理的TaskSlot个数，依据当前物理机的
taskmanager.numberOfTaskSlots: 2
#核心数来配置，一般预留出一部分核心（25%）给系统及其他进程使用，一个slot对应一个core。如果core支持超线程，那么slot个数*2
 
#指定WebUI的访问端口
rest.port: 8081

1.2 修改slaves文件

配置slave节点

node2
node3

1.3 启动集群

2. flink 高可用集群搭建

3. flink on yarn

4. filink 任务提交的两种方式

4.1 命令行提交任务

flink run -c test.WordCount -d flinkDemo-1.0-SNAPSHOT.jar

-c ：指定全限定类名

-d：后台运行

4.2 webUI页面提交

指定全限定类名

指定并行度