Matthias Pohl created FLINK-33554:
-------------------------------------
Summary: SemiJoinITCase.testRewriteScalarQueryWithCorrelation3
failed due to heartbeat timeout
Key: FLINK-33554
URL: https://issues.apache.org/jira/browse/FLINK-33554
Project: Flink
Issue Type: Sub-task
Components: Tests
Reporter: Matthias Pohl
https://github.com/XComp/flink/actions/runs/6868936761/job/18680976575#step:12:11771
{code}
[...]
Nov 14 22:16:06 Caused by: org.apache.flink.runtime.JobException: Recovery is
suppressed by NoRestartBackoffTimeStrategy
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:176)
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:107)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:285)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:276)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:269)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:765)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:742)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1645)
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1144)
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1084)
Nov 14 22:16:06 at
org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:785)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
Nov 14 22:16:06 at
org.apache.flink.runtime.scheduler.SimpleExecutionSlotAllocator$LogicalSlotHolder.release(SimpleExecutionSlotAllocator.java:203)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:482)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:474)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:445)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:275)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:231)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:549)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.handleTaskManagerConnectionLoss(JobMaster.java:1469)
Nov 14 22:16:06 at
org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1464)
Nov 14 22:16:06 at
org.apache.flink.runtime.heartbeat.DefaultHeartbeatMonitor.run(DefaultHeartbeatMonitor.java:158)
Nov 14 22:16:06 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
Nov 14 22:16:06 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
Nov 14 22:16:06 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:451)
Nov 14 22:16:06 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
Nov 14 22:16:06 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:451)
Nov 14 22:16:06 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:218)
Nov 14 22:16:06 at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85)
Nov 14 22:16:06 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168)
Nov 14 22:16:06 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
Nov 14 22:16:06 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
Nov 14 22:16:06 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
Nov 14 22:16:06 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
Nov 14 22:16:06 at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
Nov 14 22:16:06 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
Nov 14 22:16:06 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
Nov 14 22:16:06 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
Nov 14 22:16:06 at
org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
Nov 14 22:16:06 at
org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
Nov 14 22:16:06 at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
Nov 14 22:16:06 at
org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
Nov 14 22:16:06 at
org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
Nov 14 22:16:06 at
org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280)
Nov 14 22:16:06 at
org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241)
Nov 14 22:16:06 at
org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253)
Nov 14 22:16:06 ... 4 more
Nov 14 22:16:06 Caused by: java.util.concurrent.TimeoutException: Heartbeat of
TaskManager with id ced94aab-3f37-4d9c-b8b7-86af1e5df83a timed out.
Nov 14 22:16:06 ... 30 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
