Flink集群  JobManager TaskManager 

至少一个 JobManager 和一个或者多个 TaskManager
高可用（HA）模式中，可能有多个 JobManager，其中一个 leader，其他的则是 standby


Flink的高可用（HA）原理主要通过ZooKeeper实现主节点的选举和状态管理。
Flink集群中的JobManager负责计算资源管理和任务分发，而TaskManager则定期向JobManager汇报状态。
为了防止单点故障，需要配置ZooKeeper来保证JobManager的高可用性，
这包括设置ZooKeeper quorum以及将所有JobManager主机及其Web UI端口写入配置文件




启动Flink集群

启动整个Flink集群
启动整个Flink集群，包括JobManager和TaskManager
./bin/start-cluster.sh  


单独启动JobManager
./bin/jobmanager.sh  start 

单独启动TaskManager
./bin/taskmanager.sh  start 



停止Flink集群

停止整个Flink集群
停止整个Flink集群，包括JobManager和TaskManager
./bin/stop-cluster.sh  

单独停止JobManager
./bin/jobmanager.sh  stop 

单独停止TaskManager
./bin/taskmanager.sh  stop 




/app/flink/fink-1.18.0/conf
masters 
192.168.1.10:8081
192.168.1.11:8081
192.168.1.12:8081

works 

192.168.1.10
192.168.1.11
192.168.1.12
192.168.1.13
192.168.1.14