You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/08 02:08:00 UTC
[jira] [Created] (FLINK-22908)
FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails
on azure
Xintong Song created FLINK-22908:
------------------------------------
Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure
Key: FLINK-22908
URL: https://issues.apache.org/jira/browse/FLINK-22908
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.14.0
Reporter: Xintong Song
Fix For: 1.14.0
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=18754&view=logs&j=77a9d8e1-d610-59b3-fc2a-4766541e0e33&t=7c61167f-30b3-5893-cc38-a9e3d057e392&l=7744
{code}
Jun 08 00:03:01 at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
Jun 08 00:03:01 at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
Jun 08 00:03:01 at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
Jun 08 00:03:01 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
Jun 08 00:03:01 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
Jun 08 00:03:01 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
Jun 08 00:03:01 Caused by: org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Discard message, because the rpc endpoint akka://flink/user/rpc/resourcemanager_2 has not been started yet.
Jun 08 00:03:01 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:170)
Jun 08 00:03:01 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
Jun 08 00:03:01 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
Jun 08 00:03:01 at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
Jun 08 00:03:01 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
Jun 08 00:03:01 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
Jun 08 00:03:01 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
Jun 08 00:03:01 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
Jun 08 00:03:01 at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
Jun 08 00:03:01 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
Jun 08 00:03:01 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
Jun 08 00:03:01 at akka.actor.ActorCell.invoke(ActorCell.scala:561)
Jun 08 00:03:01 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
Jun 08 00:03:01 at akka.dispatch.Mailbox.run(Mailbox.scala:225)
Jun 08 00:03:01 at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
Jun 08 00:03:01 at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
Jun 08 00:03:01 at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
Jun 08 00:03:01 at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
Jun 08 00:03:01 at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)