为了将flink应用程序部署从会话模式更改为作业模式,是否有一本食谱精确描述了应该在哪个配置文件(job manager config/flink-conf.yaml、task manager config/flink-conf.yaml、job manager config/zoo.cfg……)中更改哪些内容?
此外,我们在openshift上通过一个提供给我们的ansible角色设置了flink cluster,但不幸的是,它不是从ansible galaxy存储库获取的,所以我无法向您引用任何已发布的设置。可能,大多数配置更改都必须在那里完成,在所提到的config flink文件之外。
我不明白的是,如何控制提交一个新作业会自动为每个作业生成一对新的作业管理器和一个任务管理器(1+1)示例,而不是仅使用一个作业管理器和预定义数量的任务管理器中的可用任务槽?我们目前有一个作业管理器和两个任务管理器,每个任务管理器有10个任务槽(taskmanager.numberoff)taskslots:10 line 在task manager config/flink-conf.yaml)中,总共有20个任务槽。
1条答案
按热度按时间55ooxyrt1#
你说得对,你的问题真的超出了Flink的范围。手动设置会话集群很容易,但是如果您想为每个作业都创建一个新集群,这就需要一些自动化。
管理flink有各种各样的解决方案。您可能需要调查ververica平台或flinkk8soperator之类的东西是否能满足您的需求。