Hey Endre, Thanks for the response. I need to create a small example that demonstrates the behavior because the production stream is big and gnarly. Once I get that done I will open an issue.
Thanks, Spencer On Thursday, June 9, 2016 at 3:50:02 AM UTC-6, Akka Team wrote: > > Hi Spencer, > > This looks like a bug to me. I vaguely recall a similar issue being filed, > but I cannot find it. Can you please post your findings as an issue so we > can follow up? > > Thank you, > -Endre > > On Mon, Jun 6, 2016 at 7:14 PM, Spencer Stejskal < > [email protected] <javascript:>> wrote: > >> I have a graph that is leaking http connections from an Akka-Http >> Superpool when the graph fails. The general shape of the graph is: >> >> A ~> B ~> C ~> D ~> E ~> F >> >> The stage actions are: >> A emits HttpRequests >> B is the superpool (created by Http().superPool()) >> C does some validation on the HttpResponse but leaves the ResponseEntity >> alone >> D uses flatMapConcat to emit the ResponseEntity ByteString Sources >> E Collects the ResponseEntity ByteStrings into a single chunk >> F further processes the ByteString >> >> Which all works fine if the graph completes successfully. However if >> stage F fails and fails the graph then one connection is never released and >> eventually a materialization of the graph stalls forever waiting for stage >> B to process a request. >> >> What I believe is happening is that when stage F fails, the >> ResponseEntity Source in stage C has not been sinked and so the connection >> it occupies is not released. >> >> Is there a way to sink that ResponseEntity source on graph failure or >> alternatively, is there a better way to push a series of HttpRequests >> through a superPool that is aware of the entityBody and sinks on failure? >> >> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at https://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - Reactive apps on the JVM > Blog: letitcrash.com > Twitter: @akkateam > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
