是否有一本食谱,精确描述了应该在哪个配置文件(job-manager-config/flink-conf.yaml,task-manager-config/flink-conf.yaml,job-manager-config/zoo.cfg,...(中更改什么,以便将Flink应用程序部署从会话模式更改为作业模式?
此外,我们在 openshift 上通过一个 ansible 角色进行了 flink 集群设置,不幸的是,它不是从 ansible galaxy 存储库中获取的,所以我无法引用您任何已发布的设置。可能,大多数配置更改都必须在那里完成,在上述配置 flink 文件之外。
我不明白的是,如何控制提交新作业会为每个作业自动生成一对新的作业管理器和一个任务管理器 (1+1( 实例,而不仅仅是使用一个作业管理器中的可用任务槽和预定义数量的任务管理器?我们目前有一个作业管理器和两个任务管理器,每个任务管理器有 10 个任务槽(taskmanager.numberOfTaskSlots:10 行在 task-manager-config/flink-conf.yaml 中(,总共 20 个任务槽。
你是对的,你的问题确实超出了 Flink 附带的范围。手动设置会话集群很容易,但如果您希望每个作业都有一个新集群,则需要一些自动化。
有各种解决方案可以管理 Flink。您可能想调查像Ververica Platform或flinkk8soperator这样的东西是否满足您的需求。