failed: DontLeakActorsOnFailingConnectionSpecs

[patriknw]

https://jenkins.akka.io:8498/job/akka-multi-node-nightly/4155/consoleFull

[info] DontLeakActorsOnFailingConnectionSpecs:
[info] Http.superPool
4: FAIL: akka.http.impl.engine.client.PoolSlot$UnexpectedDisconnectException: Unexpected (early) disconnect
activeShells (actor: Actor[akka://DontLeakActorsOnFailingConnectionSpecs/user/StreamSupervisor-101/flow-0-0-unknown-operation#-930512737]):
  GraphInterpreterShell
    GraphAssembly
      [ GraphStage(StatefulMapConcat) [070d76df]    [Name(iterableSource), Name(statefulMapConcat)]
        GraphStage(Map(<function1>)) [115f1049]    [Name(map)]
        GraphStage(SingleSource(Range(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100))) [09ca984e]    [Name(iterableSource), Name(singleSource)]
        GraphStage(MapAsyncUnordered(4,<function1>)) [0df51daf]    [Name(mapAsyncUnordered)]
        GraphStage(Map(<function1>)) [48f79275]    [Name(foreachSink), Name(foreachSink), Name(map)]
      ]
      [StatefulMapConcat.in,Map.in,MapAsyncUnordered.in,Map.in,null]
      [0,1,3,4,-1]
      [single.out,StatefulMapConcat.out,Map.out,MapAsyncUnordered.out,Map.out]
      [2,0,1,3,4]digraph waits {
N0 [label="StatefulMapConcat"]
N1 [label="Map(<function1>)"]
N2 [label="SingleSource(Range(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100))"]
N3 [label="MapAsyncUnordered(4,<function1>)"]
N4 [label="Map(<function1>)"]

  N1 -> N0 [label=shouldPull; color=blue]
  N3 -> N1 [label=shouldPull; color=blue]
  N3 -> N4 [label=shouldPush; color=red];
  N4 -> Out4 [label=shouldPush; color=red];
}
// (8, 29, 29)() (running=4, shutdown=1,2,0,2,2)newShells:
[info] - should not leak connection Actors when hitting non-existing endpoint *** FAILED *** (19 seconds, 973 milliseconds)
[info]   java.lang.AssertionError: assertion failed: expected no StreamSupervisor children, but got [Actor[akka://DontLeakActorsOnFailingConnectionSpecs/user/StreamSupervisor-101/flow-0-0-unknown-operation#-930512737]]
[info]   at scala.Predef$.assert(Predef.scala:170)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(Utils.scala:31)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1$$anonfun$apply$mcV$sp$1.apply(Utils.scala:28)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1$$anonfun$apply$mcV$sp$1.apply(Utils.scala:28)
[info]   at akka.testkit.TestKitBase$class.poll$2(TestKit.scala:303)
[info]   at akka.testkit.TestKitBase$class.awaitAssert(TestKit.scala:314)
[info]   at akka.testkit.TestKit.awaitAssert(TestKit.scala:814)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1.apply$mcV$sp(Utils.scala:28)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1.apply(Utils.scala:26)
[info]   at akka.stream.testkit.Utils$$anonfun$assertAllStagesStopped$1.apply(Utils.scala:26)
[info]   at akka.testkit.TestKitBase$class.within(TestKit.scala:345)
[info]   at akka.testkit.TestKit.within(TestKit.scala:814)
[info]   at akka.testkit.TestKitBase$class.within(TestKit.scala:359)
[info]   at akka.testkit.TestKit.within(TestKit.scala:814)
[info]   at akka.stream.testkit.Utils$.assertAllStagesStopped(Utils.scala:26)
[info]   at akka.http.scaladsl.server.DontLeakActorsOnFailingConnectionSpecs$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(DontLeakActorsOnFailingConnectionSpecs.scala:40)
[info]   at akka.http.scaladsl.server.DontLeakActorsOnFailingConnectionSpecs$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(DontLeakActorsOnFailingConnectionSpecs.scala:40)
[info]   at akka.http.scaladsl.server.DontLeakActorsOnFailingConnectionSpecs$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(DontLeakActorsOnFailingConnectionSpecs.scala:40)

[ktoso]

Ticket moved to github.com/akka/akka-http
Rationale for the move discussed here: akka/akka-meta#27
If you are interested in contributing or tracking this issue, please comment in akka-http instead from now on :-)