Martijn Visser created FLINK-41042:
--------------------------------------
Summary: TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails
in teardown with Boxed InterruptedException
Key: FLINK-41042
URL: https://issues.apache.org/jira/browse/FLINK-41042
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 2.3.1
Reporter: Martijn Visser
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=80199&view=logs&j=77a9d8e1-d610-59b3-fc2a-4766541e0e33
(release-2.3, nightly 2026-10-16, test_cron_azure core, JDK 17)
{code}
[ERROR]
org.apache.flink.runtime.taskexecutor.TaskExecutorTest.testHeartbeatTimeoutWithJobManager
-- Time elapsed: 0.211 s <<< ERROR!
java.util.concurrent.ExecutionException:
java.util.concurrent.ExecutionException: Boxed InterruptedException
at
org.apache.flink.runtime.rpc.RpcUtils.terminateAsyncCloseables(RpcUtils.java:115)
at
org.apache.flink.runtime.rpc.RpcUtils.terminateRpcService(RpcUtils.java:97)
at
org.apache.flink.runtime.taskexecutor.TaskExecutorTest.teardown(TaskExecutorTest.java:255)
Caused by: java.util.concurrent.ExecutionException: Boxed InterruptedException
Caused by: java.lang.InterruptedException
at scala.concurrent.Await$.result(package.scala:146)
at
org.apache.pekko.actor.LightArrayRevolverScheduler.close(LightArrayRevolverScheduler.scala:181)
at
org.apache.pekko.actor.ActorSystemImpl.stopScheduler(ActorSystem.scala:1163)
{code}
The test body passed; the failure is in {{@AfterEach}} while the Pekko actor
system shuts down its scheduler. The other 36 tests of the class passed in the
same run. It has not failed elsewhere in the 196 runs on master and the release
branches since 2026-10-09.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
