????????????????bug

Mon, 01 Jul 2024 02:14:38 -0700 

????



---- ???????????? ----
| ?????? | ????<2278179...@qq.com.INVALID> |
| ???? | 2024??06??29?? 21:31 |
| ?????? | user-zh<user-zh@flink.apache.org> |
| ?????? | |
| ???? | ?????? ??????????bug |
????


------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<cfso3...@126.com&gt;;????
????????:&nbsp;2024??6??29??(??????) ????8:24
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ??????????bug



??????????????????tm??????????????????????????????????????????????????????????????????timeout??????????????????????????
?????????6?2iPhone

&gt; ?? 2024??6??29????16:49??Zhanghao Chen <zhanghao.c...@outlook.com&gt; 
??????
&gt;
&gt; ?1?3Hi???????????? JM ???????????? TM ?? task ?????????????? JM ???????? 
HA ??????????????
&gt;
&gt; Best,
&gt; Zhanghao Chen
&gt; ________________________________
&gt; From: Cuixb <cfso3...@126.com&gt;
&gt; Sent: Saturday, June 29, 2024 10:31
&gt; To: user-zh@flink.apache.org <user-zh@flink.apache.org&gt;
&gt; Subject: ??????????bug
&gt;
&gt; ????????Flink 1.16.2
&gt;
&gt; 2024-06-29 09:17:23
&gt; java.lang.Exception: Job leader for job id 
8ccdd299194a686e3ecda602c3c75bf3 lost leadership.
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl.lambda$null$2(TaskExecutor.java:2310)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
java.util.Optional.ifPresent(Optional.java:159)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl.lambda$jobManagerLostLeadership$3(TaskExecutor.java:2308)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:453)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:453)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:218)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.actor.Actor.aroundReceive(Actor.scala:537)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.actor.Actor.aroundReceive$(Actor.scala:535)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.actor.ActorCell.invoke(ActorCell.scala:548)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.dispatch.Mailbox.run(Mailbox.scala:231)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(For
&gt;
&gt; ?????????6?2iPhone

回复