Flink Kubernetes Operator应用模式下多作业启动异常问题咨询

1. 该行为是否符合预期？ #

是，这个行为完全符合Flink Kubernetes Operator 1.4的默认预期。Operator的FlinkDeployment资源中，spec.job字段的设计目标是管控单个Flink作业的生命周期。当你的Jar包主函数启动多个作业拓扑时，Operator只会跟踪并管理第一个启动的作业，后续作业会被Operator的管控逻辑忽略——因为Operator并不识别主函数内部启动的多个作业实例，它只认为自己需要管理一个作业进程。

而原生Kubernetes应用模式下没有Operator的管控限制，Flink集群是独立运行的，主函数启动的所有作业都属于该集群，因此能正常全部启动。

2. 是否遗漏了相关配置？ #

没有遗漏核心配置，但你的配置方式不符合Operator管理多作业的设计逻辑。当前的FlinkDeployment仅定义了一个job块，Operator只会执行该配置对应的作业启动流程，无法处理主函数内的多作业逻辑。

3. Flink Kubernetes Operator是否支持启动包含多作业的应用？ #

支持，但不能通过“单Jar主函数启动多个作业”的方式实现，需要采用以下方案：

• 拆分作业为独立Jar，创建多个FlinkDeployment：将3个作业拓扑拆分为3个独立的Jar包，为每个作业创建一个FlinkDeployment资源。这种方式最贴合Operator的设计，每个作业可以独立配置资源、并行度，Operator能分别管控它们的启动、升级、故障恢复。
• 同一Jar+参数区分作业：如果不想拆分Jar，可以在主函数中通过命令行参数指定启动哪个作业拓扑，然后为每个作业创建一个FlinkDeployment，在spec.job.args中传递不同的参数，让主函数启动对应的作业。
• Session集群模式：通过Operator创建一个Flink Session集群（spec.mode: session），然后通过Flink CLI或REST API将3个作业提交到该Session集群中。这种模式下，Operator仅管控Session集群的生命周期，作业的提交和管理需要单独操作。

内容的提问来源于stack exchange，提问作者ypanag