Roman Khachatryan created FLINK-39117:
-----------------------------------------
Summary: Flaky ChainUnionTest testMigrationAndRestore
Key: FLINK-39117
URL: https://issues.apache.org/jira/browse/FLINK-39117
Project: Flink
Issue Type: Bug
Components: Tests
Affects Versions: 2.3.0
Reporter: Roman Khachatryan
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=72491&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=9d734c8c-6253-55e6-3bce-47e7cdf68ac4&l=41089]
{code}
2026-02-18T15:57:20.8683792Z Feb 18 15:57:20 15:57:20.867 [ERROR] Tests run:
16, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 9.210 s <<< FAILURE! --
in org.apache.flink.test.state.operator.restore.unkeyed.ChainUnionTest
2026-02-18T15:57:20.8685647Z Feb 18 15:57:20 15:57:20.867 [ERROR]
org.apache.flink.test.state.operator.restore.unkeyed.ChainUnionTest.testMigrationAndRestore[Migrate
Savepoint: 2.1] -- Time elapsed: 0.777 s <<< ERROR!
2026-02-18T15:57:20.8686925Z Feb 18 15:57:20
java.util.concurrent.ExecutionException:
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator
is suspending.
2026-02-18T15:57:20.8687770Z Feb 18 15:57:20 at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
2026-02-18T15:57:20.8688532Z Feb 18 15:57:20 at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
2026-02-18T15:57:20.8689415Z Feb 18 15:57:20 at
org.apache.flink.test.state.operator.restore.AbstractOperatorRestoreTestBase.migrateJob(AbstractOperatorRestoreTestBase.java:209)
2026-02-18T15:57:20.8690448Z Feb 18 15:57:20 at
org.apache.flink.test.state.operator.restore.AbstractOperatorRestoreTestBase.testMigrationAndRestore(AbstractOperatorRestoreTestBase.java:158)
2026-02-18T15:57:20.8697764Z Feb 18 15:57:20 at
java.base/java.lang.reflect.Method.invoke(Method.java:568)
2026-02-18T15:57:20.8698702Z Feb 18 15:57:20 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2026-02-18T15:57:20.8699773Z Feb 18 15:57:20 Caused by:
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator
is suspending.
2026-02-18T15:57:20.8701083Z Feb 18 15:57:20 at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.stopCheckpointScheduler(CheckpointCoordinator.java:2068)
2026-02-18T15:57:20.8702293Z Feb 18 15:57:20 at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.startCheckpointScheduler(CheckpointCoordinator.java:2054)
2026-02-18T15:57:20.8703705Z Feb 18 15:57:20 at
org.apache.flink.runtime.checkpoint.ExecutionTrackingCheckpointCoordinatorDeActivator.maybeStartOrStopCheckpointScheduler(ExecutionTrackingCheckpointCoordinatorDeActivator.java:84)
2026-02-18T15:57:20.8704949Z Feb 18 15:57:20 at
org.apache.flink.runtime.checkpoint.ExecutionTrackingCheckpointCoordinatorDeActivator.onStateUpdate(ExecutionTrackingCheckpointCoordinatorDeActivator.java:76)
2026-02-18T15:57:20.8706904Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.lambda$notifyExecutionChange$10(DefaultExecutionGraph.java:1724)
2026-02-18T15:57:20.8707939Z Feb 18 15:57:20 at
java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
2026-02-18T15:57:20.8708789Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifyExecutionChange(DefaultExecutionGraph.java:1723)
2026-02-18T15:57:20.8709697Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.ExecutionVertex.notifyStateTransition(ExecutionVertex.java:571)
2026-02-18T15:57:20.8710517Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.Execution.transitionState(Execution.java:1686)
2026-02-18T15:57:20.8711293Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.Execution.transitionState(Execution.java:1639)
2026-02-18T15:57:20.8712063Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.Execution.switchTo(Execution.java:1425)
2026-02-18T15:57:20.8712821Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.Execution.switchToRunning(Execution.java:1420)
2026-02-18T15:57:20.8713732Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.updateStateInternal(DefaultExecutionGraph.java:1468)
2026-02-18T15:57:20.8714635Z Feb 18 15:57:20 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.updateState(DefaultExecutionGraph.java:1437)
2026-02-18T15:57:20.8715811Z Feb 18 15:57:20 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:812)
2026-02-18T15:57:20.8717030Z Feb 18 15:57:20 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83)
2026-02-18T15:57:20.8718467Z Feb 18 15:57:20 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:534)
2026-02-18T15:57:20.8719322Z Feb 18 15:57:20 at
java.base/java.lang.reflect.Method.invoke(Method.java:568)
2026-02-18T15:57:20.8720084Z Feb 18 15:57:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318)
2026-02-18T15:57:20.8720957Z Feb 18 15:57:20 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2026-02-18T15:57:20.8721808Z Feb 18 15:57:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316)
2026-02-18T15:57:20.8722607Z Feb 18 15:57:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229)
2026-02-18T15:57:20.8723510Z Feb 18 15:57:20 at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
2026-02-18T15:57:20.8724346Z Feb 18 15:57:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
2026-02-18T15:57:20.8725096Z Feb 18 15:57:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
2026-02-18T15:57:20.8725879Z Feb 18 15:57:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
2026-02-18T15:57:20.8726743Z Feb 18 15:57:20 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
2026-02-18T15:57:20.8727413Z Feb 18 15:57:20 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
2026-02-18T15:57:20.8728120Z Feb 18 15:57:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
2026-02-18T15:57:20.8728843Z Feb 18 15:57:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
2026-02-18T15:57:20.8729535Z Feb 18 15:57:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2026-02-18T15:57:20.8730224Z Feb 18 15:57:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
2026-02-18T15:57:20.8731018Z Feb 18 15:57:20 at
org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
2026-02-18T15:57:20.8731679Z Feb 18 15:57:20 at
org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
2026-02-18T15:57:20.8732369Z Feb 18 15:57:20 at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
2026-02-18T15:57:20.8733127Z Feb 18 15:57:20 at
org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
2026-02-18T15:57:20.8733878Z Feb 18 15:57:20 at
org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
2026-02-18T15:57:20.8734547Z Feb 18 15:57:20 at
org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
2026-02-18T15:57:20.8735215Z Feb 18 15:57:20 at
org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
2026-02-18T15:57:20.8735924Z Feb 18 15:57:20 at
org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
2026-02-18T15:57:20.8736769Z Feb 18 15:57:20 at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
2026-02-18T15:57:20.8737520Z Feb 18 15:57:20 at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
2026-02-18T15:57:20.8738275Z Feb 18 15:57:20 at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
2026-02-18T15:57:20.8738988Z Feb 18 15:57:20 at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
2026-02-18T15:57:20.8739733Z Feb 18 15:57:20 at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
2026-02-18T15:57:20.8740346Z Feb 18 15:57:20
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
