[
https://issues.apache.org/jira/browse/FLINK-17643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106047#comment-17106047
]
Till Rohrmann commented on FLINK-17643:
---------------------------------------
The problem seems to be caused by
{code}
1:55:03,470 [flink-akka.actor.default-dispatcher-3] ERROR
akka.actor.LocalActorRefProvider(akka://flink) [] - guardian
failed, shutting down system
java.lang.NullPointerException: null
at
org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:208)
~[classes/:?]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:162)
~[classes/:?]
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
~[scala-library-2.11.12.jar:?]
at akka.actor.FSM$class.processEvent(FSM.scala:684)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:50)
~[classes/:?]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:638)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:50)
~[classes/:?]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.process$1(CallingThreadDispatcher.scala:251)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.runQueue(CallingThreadDispatcher.scala:284)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.dispatch(CallingThreadDispatcher.scala:208)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at akka.actor.dungeon.Dispatch$class.sendMessage(Dispatch.scala:142)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.sendMessage(ActorCell.scala:429)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Cell$class.sendMessage(ActorCell.scala:350)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.sendMessage(ActorCell.scala:429)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.LocalActorRef.$bang(ActorRef.scala:402)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Scheduler$$anon$3.run(Scheduler.scala:171)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.executeTask(CallingThreadDispatcher.scala:213)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.dispatch.MessageDispatcher.unbatchedExecute(AbstractDispatcher.scala:146)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.dispatch.BatchingExecutor$class.execute(BatchingExecutor.scala:123)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.dispatch.MessageDispatcher.execute(AbstractDispatcher.scala:86)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:279)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:283)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_242]
11:55:03,475 [flink-akka.actor.default-dispatcher-3] ERROR
akka.actor.OneForOneStrategy [] - null
java.lang.NullPointerException: null
at
org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:208)
~[classes/:?]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:162)
~[classes/:?]
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
~[scala-library-2.11.12.jar:?]
at akka.actor.FSM$class.processEvent(FSM.scala:684)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:50)
~[classes/:?]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:638)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:50)
~[classes/:?]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.process$1(CallingThreadDispatcher.scala:251)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.runQueue(CallingThreadDispatcher.scala:284)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.dispatch(CallingThreadDispatcher.scala:208)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at akka.actor.dungeon.Dispatch$class.sendMessage(Dispatch.scala:142)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.sendMessage(ActorCell.scala:429)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Cell$class.sendMessage(ActorCell.scala:350)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.ActorCell.sendMessage(ActorCell.scala:429)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.LocalActorRef.$bang(ActorRef.scala:402)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.actor.Scheduler$$anon$3.run(Scheduler.scala:171)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.testkit.CallingThreadDispatcher.executeTask(CallingThreadDispatcher.scala:213)
~[akka-testkit_2.11-2.5.21.jar:2.5.21]
at
akka.dispatch.MessageDispatcher.unbatchedExecute(AbstractDispatcher.scala:146)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.dispatch.BatchingExecutor$class.execute(BatchingExecutor.scala:123)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at akka.dispatch.MessageDispatcher.execute(AbstractDispatcher.scala:86)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:279)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:283)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at
akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_242]
{code}
> LaunchCoordinatorTest fails
> ---------------------------
>
> Key: FLINK-17643
> URL: https://issues.apache.org/jira/browse/FLINK-17643
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Mesos
> Reporter: Arvid Heise
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.11.0
>
>
> Here is the
> [instance|https://dev.azure.com/arvidheise0209/arvidheise/_build/results?buildId=234&view=logs&j=764762df-f65b-572b-3d5c-65518c777be4&t=8d823410-c7c7-5a4d-68bb-fa7b08da17b9].
>
> {noformat}
> [ERROR] Tests run: 24, Failures: 0, Errors: 4, Skipped: 0, Time elapsed:
> 1.828 s <<< FAILURE! - in
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest
> [ERROR] The LaunchCoordinator when in state GatheringOffers should handle
> StateTimeout which stays in GatheringOffers when task queue is
> non-empty(org.apache.flink.mesos.scheduler.LaunchCoordinatorTest) Time
> elapsed: 0.021 s <<< ERROR!
> java.lang.IllegalStateException: cannot reserve actor name '$$u': terminating
> at
> akka.actor.dungeon.ChildrenContainer$TerminatingChildrenContainer.reserve(ChildrenContainer.scala:188)
> at akka.actor.dungeon.Children$class.reserveChild(Children.scala:135)
> at akka.actor.ActorCell.reserveChild(ActorCell.scala:429)
> at akka.testkit.TestActorRef.<init>(TestActorRef.scala:33)
> at akka.testkit.TestFSMRef.<init>(TestFSMRef.scala:40)
> at akka.testkit.TestFSMRef$.apply(TestFSMRef.scala:91)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest$Context.<init>(LaunchCoordinatorTest.scala:254)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest$$anonfun$1$$anonfun$apply$mcV$sp$8$$anonfun$apply$mcV$sp$15$$anonfun$apply$mcV$sp$34$$anon$25.<init>(LaunchCoordinatorTest.scala:459)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest$$anonfun$1$$anonfun$apply$mcV$sp$8$$anonfun$apply$mcV$sp$15$$anonfun$apply$mcV$sp$34.apply(LaunchCoordinatorTest.scala:459)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest$$anonfun$1$$anonfun$apply$mcV$sp$8$$anonfun$apply$mcV$sp$15$$anonfun$apply$mcV$sp$34.apply(LaunchCoordinatorTest.scala:459)
> at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
> at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
> at org.scalatest.Transformer.apply(Transformer.scala:22)
> at org.scalatest.Transformer.apply(Transformer.scala:20)
> at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:1078)
> at org.scalatest.TestSuite$class.withFixture(TestSuite.scala:196)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest.withFixture(LaunchCoordinatorTest.scala:57)
> at
> org.scalatest.WordSpecLike$class.invokeWithFixture$1(WordSpecLike.scala:1075)
> at
> org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:1088)
> at
> org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:1088)
> at org.scalatest.SuperEngine.runTestImpl(Engine.scala:289)
> at org.scalatest.WordSpecLike$class.runTest(WordSpecLike.scala:1088)
> at
> org.apache.flink.mesos.scheduler.LaunchCoordinatorTest.runTest(LaunchCoordinatorTest.scala:57)
> at
> org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1147)
> at
> org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1147)
> at
> org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:396)
> at
> org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:384)
> at scala.collection.immutable.List.foreach(List.scala:392)
> at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:384)
> at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418){noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
