????
---- ???????????? ----
| ?????? | 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??????????????????????????
?????????6?2iPhone
> ?? 2024??6??29????16:49??Zhanghao Chen <zhanghao.c...@outlook.com>
??????
>
> ?1?3Hi???????????? 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
>
> ?????????6?2iPhone
