Flink集群部署

安装帮助:  https://www.jianshu.com/p/c47e8f438291

注意: 所有节点的配置一样  

访问集群web界面  http://JobManager:8081/

在已经运行的集群中添加JobManager/TaskManager

  我们可以通过bin/taskmanager.sh或者bin/jobmanager.sh脚本在已经运行的集群中添加JobManager或者TaskManager节点

添加一个JobManager

$ bin/jobmanager.sh (start cluster)|stop|stop-all

添加一个TaskManager

$ bin/taskmanager.sh start|stop|stop-all



image

增加kerberos认证

security.kerberos.login.use-ticket-cache: true
security.kerberos.login.keytab: /opt/yarn.keytab
security.kerberos.login.principal: yarn

测试  :

以集群模式提交任务

bin/flink run -m yarn-cluster examples/batch/WordCount.jar --port 9000


image


Flink 配置文件详解:

https://www.jianshu.com/p/f64668d7e396


您可以选择一种方式赞助本站

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

图片 表情