问个小白问题,启动命令设置的5个并行度,3个slot,造成有两个Task Managers,现在我想要只有一个Task Managers,那么我启动命令设置slot格式为6,但是为什么我的flink cdc程序一直在create中?胡Loong: 我flinkcdc的启动命令是flink run -t yarn-per-job -Dyarn.application.name=KAFKA -Dparallelism.default=5 -Djobmanager.memory.process.size=1024MB -Dtaskmanager.memory.process.size=2048MB -Dtaskmanager.numberOfTaskSlots=3
胡Loong: 把slot,从3改成6,就启动不起来了。。。 一直在created阶段,然后就挂掉了
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据您提供的信息,您在尝试通过增加TaskManager的槽位数(task slots)来减少Task Managers的数量,但遇到了程序启动后一直停留在"created"状态并最终失败的问题。结合您的描述和参考资料,我们可以分析并提供以下建议:
问题描述: 您希望将Flink作业配置为仅使用一个Task Manager,并通过增加槽位数从3改为6来实现。但在调整-Dtaskmanager.numberOfTaskSlots=6
后,Flink CDC程序无法正常启动,卡在"created"状态并最终失败。
原因分析:
解决方案:
-Dtaskmanager.memory.process.size
),确保在增加槽位的同时不会因资源不足导致任务失败。注意事项:
请按照上述步骤进行检查和调整,如果问题依旧,请提供更详细的错误日志或描述,以便进一步分析。