建议检查一下JM的GC情况。 wjw_bigd...@163.com <wjw_bigd...@163.com> 于2024年7月1日周一 17:18写道：
> 退订 > > > > ---- 回复的原邮件 ---- > | 发件人 | wjw_bigd...@163.com | > | 日期 | 2024年07月01日 17:13 | > | 收件人 | user-zh<user-zh@flink.apache.org> | > | 抄送至 | | > | 主题 | 回复：这绝对算是bug | > 退订 > > > > ---- 回复的原邮件 ---- > | 发件人 | 星海<2278179...@qq.com.INVALID> | > | 日期 | 2024年06月29日 21:31 | > | 收件人 | user-zh<user-zh@flink.apache.org> | > | 抄送至 | | > | 主题 | 回复： 这绝对算是bug | > 退订 > > > ------------------ 原始邮件 ------------------ > 发件人: > "user-zh" > < > cfso3...@126.com>;退订 > 发送时间: 2024年6月29日(星期六) 晚上8:24 > 收件人: "user-zh"<user-zh@flink.apache.org>; > > 主题: Re: 这绝对算是bug > > > > 连接没问题，主要是tm一直在处理写入流，我也看了一下负载，其实不高，但就是不相应，导致报timeout，然后就是最开始那个错误！ > 发自我的 iPhone > > > 在 2024年6月29日，16:49，Zhanghao Chen <zhanghao.c...@outlook.com> 写道： > > > > Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？ > > > > Best, > > Zhanghao Chen > > ________________________________ > > From: Cuixb <cfso3...@126.com> > > Sent: Saturday, June 29, 2024 10:31 > > To: user-zh@flink.apache.org <user-zh@flink.apache.org> > > Subject: 这绝对算是bug > > > > 生产环境Flink 1.16.2 > > > > 2024-06-29 09:17:23 > > java.lang.Exception: Job leader for job id > 8ccdd299194a686e3ecda602c3c75bf3 lost leadership. > > at > org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl.lambda$null$2(TaskExecutor.java:2310) > > at > java.util.Optional.ifPresent(Optional.java:159) > > at > org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl.lambda$jobManagerLostLeadership$3(TaskExecutor.java:2308) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:453) > > at > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:453) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:218) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168) > > at akka.japi.pf > .UnitCaseStatement.apply(CaseStatements.scala:24) > > at akka.japi.pf > .UnitCaseStatement.apply(CaseStatements.scala:20) > > at > scala.PartialFunction.applyOrElse(PartialFunction.scala:123) > > at > scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) > > at akka.japi.pf > .UnitCaseStatement.applyOrElse(CaseStatements.scala:20) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > > at > akka.actor.Actor.aroundReceive(Actor.scala:537) > > at > akka.actor.Actor.aroundReceive$(Actor.scala:535) > > at > akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) > > at > akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) > > at > akka.actor.ActorCell.invoke(ActorCell.scala:548) > > at > akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) > > at > akka.dispatch.Mailbox.run(Mailbox.scala:231) > > at > akka.dispatch.Mailbox.exec(Mailbox.scala:243) > > at > java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) > > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(For > > > > 发自我的 iPhone
