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 Standalone(单机)集群部署

 

配置 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

Flink Standalone(单机)集群部署

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

Flink Standalone(单机)集群部署

 

查看UI

http://localhost:8086/#/overview

Flink Standalone(单机)集群部署

 

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

 


 

欢迎点赞关注和收藏

Flink Standalone(单机)集群部署

 

上一篇:安装nocas


下一篇:手把手教你使用Selenium Grid实现分布式自动化测试【建议收藏】