从日志看,ZK 集群滚动的时候发生了切主,两个 JM 都先后成为过 Leader,但是并没有同时是 Leader。

Best,
Zhanghao Chen
________________________________
From: love_h1...@126.com <love_h1...@126.com>
Sent: Friday, July 12, 2024 17:17
To: user-zh@flink.apache.org <user-zh@flink.apache.org>
Subject: Flink Standalone-ZK-HA模式下,CLi任务提交

版本:Flink 1.11.6版本,Standalone HA模式,ZooKeeper 3.5.8版本
操作:
     1. 只cancel了所有正在运行的Job,没有Stop Flink集群
     2. 滚动重启Zookeeper集群
     3. 使用 Flink run 命令提交多个Job
现象:
1. 部分Job提交失败,错误信息为 The rpc invocation size 721919700 exceeds the maximum akka 
framesize.
2. Flink 集群有两个JobManager节点的日志中出现了任务接收和执行的信息
疑问:
1. 使用Flink run 命令提交任务会提交到Flink 集群中的两个JobManager节点么
2. 重启Zookeeper集群会导致Flink集群中出现两个Leader角色的JobManager,这是否是一个特殊场景下的BUG



回复