You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "wjw_bigdata@163.com" <wj...@163.com> on 2024/07/01 09:13:03 UTC
回复：这绝对算是bug
退订
---- 回复的原邮件 ----
| 发件人 | 星海<22...@qq.com.INVALID> |
| 日期 | 2024年06月29日 21:31 |
| 收件人 | user-zh<us...@flink.apache.org> |
| 抄送至 | |
| 主题 | 回复： 这绝对算是bug |
退订
------------------ 原始邮件 ------------------
发件人: "user-zh" <cfso3656@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.chen@outlook.com> 写道：
>
> Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
>
> Best,
> Zhanghao Chen
> ________________________________
> From: Cuixb <cfso3656@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
Re: 这绝对算是bug
Posted by Yan Zhou <ya...@thoughtworks.com>.
退订
On Mon, Jul 1, 2024 at 10:22 PM wjw_bigdata@163.com <wj...@163.com>
wrote:
> 退订
>
>
>
> ---- 回复的原邮件 ----
> | 发件人 | Cuixb<cf...@126.com> |
> | 日期 | 2024年07月01日 22:16 |
> | 收件人 | user-zh@flink.apache.org |
> | 抄送至 | |
> | 主题 | Re: 这绝对算是bug |
> GC不能说长，也绝对不短，大概计算了一下，24G内存，得有10秒左右无响应，多数在10秒内
> 发自我的 iPhone
>
> > 在 2024年7月1日，17:20，rui chen <ru...@gmail.com> 写道：
> >
> > 建议检查一下JM的GC情况。
> >
> > wjw_bigdata@163.com <wj...@163.com> 于2024年7月1日周一 17:18写道：
> >
> >> 退订
> >>
> >>
> >>
> >> ---- 回复的原邮件 ----
> >> | 发件人 | wjw_bigdata@163.com |
> >> | 日期 | 2024年07月01日 17:13 |
> >> | 收件人 | user-zh<us...@flink.apache.org> |
> >> | 抄送至 | |
> >> | 主题 | 回复：这绝对算是bug |
> >> 退订
> >>
> >>
> >>
> >> ---- 回复的原邮件 ----
> >> | 发件人 | 星海<22...@qq.com.INVALID> |
> >> | 日期 | 2024年06月29日 21:31 |
> >> | 收件人 | user-zh<us...@flink.apache.org> |
> >> | 抄送至 | |
> >> | 主题 | 回复： 这绝对算是bug |
> >> 退订
> >>
> >>
> >> ------------------ 原始邮件 ------------------
> >> 发件人:
> >> "user-zh"
> >> <
> >> cfso3656@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.chen@outlook.com>
> 写道：
> >> >
> >> > Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
> >> >
> >> > Best,
> >> > Zhanghao Chen
> >> > ________________________________
> >> > From: Cuixb <cfso3656@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
> >
回复：这绝对算是bug
Posted by "wjw_bigdata@163.com" <wj...@163.com>.
退订
---- 回复的原邮件 ----
| 发件人 | Cuixb<cf...@126.com> |
| 日期 | 2024年07月01日 22:16 |
| 收件人 | user-zh@flink.apache.org |
| 抄送至 | |
| 主题 | Re: 这绝对算是bug |
GC不能说长，也绝对不短，大概计算了一下，24G内存，得有10秒左右无响应，多数在10秒内
发自我的 iPhone
> 在 2024年7月1日，17:20，rui chen <ru...@gmail.com> 写道：
>
> 建议检查一下JM的GC情况。
>
> wjw_bigdata@163.com <wj...@163.com> 于2024年7月1日周一 17:18写道：
>
>> 退订
>>
>>
>>
>> ---- 回复的原邮件 ----
>> | 发件人 | wjw_bigdata@163.com |
>> | 日期 | 2024年07月01日 17:13 |
>> | 收件人 | user-zh<us...@flink.apache.org> |
>> | 抄送至 | |
>> | 主题 | 回复：这绝对算是bug |
>> 退订
>>
>>
>>
>> ---- 回复的原邮件 ----
>> | 发件人 | 星海<22...@qq.com.INVALID> |
>> | 日期 | 2024年06月29日 21:31 |
>> | 收件人 | user-zh<us...@flink.apache.org> |
>> | 抄送至 | |
>> | 主题 | 回复： 这绝对算是bug |
>> 退订
>>
>>
>> ------------------ 原始邮件 ------------------
>> 发件人:
>> "user-zh"
>> <
>> cfso3656@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.chen@outlook.com> 写道：
>> >
>> > Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
>> >
>> > Best,
>> > Zhanghao Chen
>> > ________________________________
>> > From: Cuixb <cfso3656@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
>
Re: 这绝对算是bug
Posted by Cuixb <cf...@126.com>.
GC不能说长，也绝对不短，大概计算了一下，24G内存，得有10秒左右无响应，多数在10秒内
发自我的 iPhone
> 在 2024年7月1日，17:20，rui chen <ru...@gmail.com> 写道：
>
> 建议检查一下JM的GC情况。
>
> wjw_bigdata@163.com <wj...@163.com> 于2024年7月1日周一 17:18写道：
>
>> 退订
>>
>>
>>
>> ---- 回复的原邮件 ----
>> | 发件人 | wjw_bigdata@163.com |
>> | 日期 | 2024年07月01日 17:13 |
>> | 收件人 | user-zh<us...@flink.apache.org> |
>> | 抄送至 | |
>> | 主题 | 回复：这绝对算是bug |
>> 退订
>>
>>
>>
>> ---- 回复的原邮件 ----
>> | 发件人 | 星海<22...@qq.com.INVALID> |
>> | 日期 | 2024年06月29日 21:31 |
>> | 收件人 | user-zh<us...@flink.apache.org> |
>> | 抄送至 | |
>> | 主题 | 回复： 这绝对算是bug |
>> 退订
>>
>>
>> ------------------ 原始邮件 ------------------
>> 发件人:
>> "user-zh"
>> <
>> cfso3656@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.chen@outlook.com> 写道：
>> >
>> > Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
>> >
>> > Best,
>> > Zhanghao Chen
>> > ________________________________
>> > From: Cuixb <cfso3656@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
>
Re: 这绝对算是bug
Posted by rui chen <ru...@gmail.com>.
建议检查一下JM的GC情况。
wjw_bigdata@163.com <wj...@163.com> 于2024年7月1日周一 17:18写道：
> 退订
>
>
>
> ---- 回复的原邮件 ----
> | 发件人 | wjw_bigdata@163.com |
> | 日期 | 2024年07月01日 17:13 |
> | 收件人 | user-zh<us...@flink.apache.org> |
> | 抄送至 | |
> | 主题 | 回复：这绝对算是bug |
> 退订
>
>
>
> ---- 回复的原邮件 ----
> | 发件人 | 星海<22...@qq.com.INVALID> |
> | 日期 | 2024年06月29日 21:31 |
> | 收件人 | user-zh<us...@flink.apache.org> |
> | 抄送至 | |
> | 主题 | 回复： 这绝对算是bug |
> 退订
>
>
> ------------------ 原始邮件 ------------------
> 发件人:
> "user-zh"
> <
> cfso3656@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.chen@outlook.com> 写道：
> >
> > Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
> >
> > Best,
> > Zhanghao Chen
> > ________________________________
> > From: Cuixb <cfso3656@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
回复：这绝对算是bug
Posted by "wjw_bigdata@163.com" <wj...@163.com>.
退订
---- 回复的原邮件 ----
| 发件人 | wjw_bigdata@163.com |
| 日期 | 2024年07月01日 17:13 |
| 收件人 | user-zh<us...@flink.apache.org> |
| 抄送至 | |
| 主题 | 回复：这绝对算是bug |
退订
---- 回复的原邮件 ----
| 发件人 | 星海<22...@qq.com.INVALID> |
| 日期 | 2024年06月29日 21:31 |
| 收件人 | user-zh<us...@flink.apache.org> |
| 抄送至 | |
| 主题 | 回复： 这绝对算是bug |
退订
------------------ 原始邮件 ------------------
发件人: "user-zh" <cfso3656@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.chen@outlook.com> 写道：
>
> Hi，从报错看是 JM 丢主了，导致 TM 上 task 全部关停。看下 JM 侧是不是 HA 连接有问题呢？
>
> Best,
> Zhanghao Chen
> ________________________________
> From: Cuixb <cfso3656@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