flink单个taskmanager只能提交64个job嘛?slot和内存资源都充足的情况下,新提交的任务报Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout
在Flink中,每个TaskManager实例可以提交的Job数量是由其内存资源和队列资源决定的。如果一个TaskManager实例的内存资源和队列资源都充足,那么它最多可以提交的Job数量是由其配置参数决定的。 在Flink中,可以通过以下参数来调整TaskManager实例的Job提交数量:
min_parallelism_for_all_tasks:每个任务最小的并行度。 max_parallelism_for_all_tasks:每个任务最大的并行度。 如果你想要提交更多的Job,可以将这些参数设置为更大的值。 另外,如果你的Slot Request Bulk 没有及时完成,可能是由于以下原因:
队列满了:如果你的队列满了,那么你无法再提交新的Job。你可以通过调整队列的大小或者增加队列的数量来解决这个问题。 没有足够的内存资源:如果你的内存资源不足,那么你可能无法提交新的Job。你可以通过增加TaskManager实例的内存资源或者调整内存的分配方式来解决这个问题。 因此,要解决你的问题,需要查看你的配置参数和系统状态,以确定你的TaskManager实例能够提交多少个Job。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。