Flink Standalone（单机）集群部署

原创转载请注明出处：https://www.cnblogs.com/agilestyle/p/14688963.html

下载

wget https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.12.tgz

解压

tar zxvf flink-1.12.2-bin-scala_2.12.tgz -C ~/app

cd

cd ~/app/flink-1.12.2/conf
ls -lrth

配置 flink-conf.yaml 

vi flink-conf.yaml

jobmanager.rpc.address: localhost
jobmanager.rpc.port: 6123
jobmanager.memory.process.size: 2048m
taskmanager.memory.process.size: 4096m
taskmanager.numberOfTaskSlots: 4
rest.port: 8086

Note: flink默认的rest.port的端口的是8081，由于本机上配置8081，导致StandaloneSessionClusterEntrypoint 起不来，所以配置成了8086

配置masters

vi masters

localhost:8086

配置workers

vi workers

localhost

启动

cd ~/app/flink-1.12.2/bin
./start-cluster.sh

Note: 停止使用 ./stop-cluster.sh 

jps

查看UI

http://localhost:8086/#/overview

Reference

https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/standalone/

https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/config.html

---

欢迎点赞关注和收藏