flink部署模式

# standalone 模式的部署只需要修改两个配置文件 - $FLINK_HOME/conf
# 1.flink-conf.yaml
# jobmanager.rpc.address 指定jobmanager的address(主节点，ip地址或者主机名皆可)
jobmanager.rpc.address: master
# jobmanager.rpc.port 指定jobmanager的通信端口(一般为默认)
jobmanager.rpc.port: 6123
# jobmanager.memory.process.size 指定jobmanager的内存大小
jobmanager.memory.process.size: 1600m
# taskmanager.memory.process.size 指定taskmanager的内存大小
taskmanager.memory.process.size: 1728m
# taskmanager.numberOfTaskSlots 指定taskmanager的插槽数量
taskmanager.numberOfTaskSlots: 2

# 2.workers文件
# workers 文件用于指定taskmanager的节点主机(ip地址或者主机名皆可)
worker1
worker2

# 3.启动standalone模式
$FLINK_HOME/bin/start-cluster.sh

# 4.检查是否运行成功 - jps查看进程
# jobmanager节点进程为
StandaloneSessionClusterEntrypoint # jobmanager的守护进程
# taskmanager节点进程为
TaskManagerRunner # taskmanager的守护进程