大家有没有docker部署的?如果我在同一台机器上部署两个jobmanager,这块的端口是怎么配的?
在在同一台机器上部署两个Flink JobManager时,需要确保它们使用的端口不冲突,以避免端口被占用的问题。具体来说,可以通过修改flink-conf.yaml配置文件中的相关配置项来配置JobManager的端口。
在Flink 1.13及以后版本中,可以通过以下两个参数来配置JobManager的端口:
jobmanager.rpc.address:指定JobManager的RPC地址,默认为localhost。
jobmanager.rpc.port:指定JobManager的RPC端口,默认为6123。
可以通过在flink-conf.yaml文件中添加以下配置来修改JobManager的端口:
Copy
jobmanager.rpc.address:
jobmanager.rpc.port:
需要注意的是,如果需要在同一台机器上部署多个JobManager实例,需要确保它们使用的端口不冲突,并且需要为每个JobManager实例配置不同的RPC地址和端口。同时,需要考虑到资源分配和调度等问题,避免出现资源争夺和调度冲突等问题
docker部署的话上生产的话不理想在高可用这部分,还是走k8s好点https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.6/docs/development/guide/,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。