Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。

退订 发自我的 iPhone > 在 2022年10月28日，11:41，Weihua Hu 写道： > > Hi, Young > > 你的分析是正确的。Flink kubernetes operator 是通过 rest service 来跟 Flink cluster > 通信的，Kubernetes 会随机将发往 service 的请求路由到后端的多个 JM Pod > 上。任务提交流程分为了：uploadJar,runJob,deleteJar 三个 API，所以会在 opeartor 的日志里看到相关的错误。 > > 也许你可以创建一个 jira issue 来跟进

Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。

Hi, Young 你的分析是正确的。Flink kubernetes operator 是通过 rest service 来跟 Flink cluster 通信的，Kubernetes 会随机将发往 service 的请求路由到后端的多个 JM Pod 上。任务提交流程分为了：uploadJar,runJob,deleteJar 三个 API，所以会在 opeartor 的日志里看到相关的错误。 也许你可以创建一个 jira issue 来跟进这个问题 Best, Weihua On Thu, Oct 27, 2022 at 6:51 PM Young Chen wrote:

Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。

【问题描述】 Flink k8s operator(v1.1.0)高可用部署了一个Flink Session Cluster(两个JobManager), 然后用SessionJob 部署一个例子job，job有时可以部署，有时部署不了。 可以看到容器中如下error日志。 【操作步骤】 部署Cluster apiVersion: flink.apache.org/v1beta1 kind: FlinkDeployment metadata: name: flink-cluster-1jm-checkpoint spec: image: flink:1.