flink on swarm[standalone mode]
利用swarm快速拉起flink集群,模式如下:1节点jobmanager,3节点taskmanager。实际生产中jobmanager是需要zookeeper组成HA集群的,更好的是Flink on Yarn。这里仅仅为了方便拉起flink测试集群。base: flink:latest
创建jobmanager
1 |
docker service create --name=jobmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 8081:8081 -p 6123:6123 --network=bigdata flink:latest jobmanager |
创建taskmanager
1 |
docker service create --name=taskmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 6121:6121 -p 6122:6122 --network=bigdata flink:latest taskmanager |
扩容taskmanager
1 |
docker service scale taskmanager=3 |
flink web gui
测试
未完