GC不能说长，也绝对不短，大概计算了一下，24G内存，得有10秒左右无响应，多数在10秒内 发自我的 iPhone
> 在 2024年7月1日，17:20，rui chen <ruichen...@gmail.com> 写道： > > 建议检查一下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 >
