OK, thanks. I've found the reason why my requests never come back. Even though the server responses 404, I have to consume the response body. Or the pooled connections will never get released.
On Wednesday, April 6, 2016 at 6:19:44 PM UTC+8, Konrad Malawski wrote: > > Firstly, it's a DEBUG level message – it's nothing "bad" happening. > > Simply after some time of no data being passed through a connection is is > being shut down – it's an "idle timeout", > otherwise we may end up having thousands of connections open which are > doing nothing. > > Please read the docs on this feature: > http://doc.akka.io/docs/akka/2.4.3/scala/http/common/timeouts.html > > -- > Cheers, > Konrad 'ktoso’ Malawski > <http://akka.io>Akka <http://akka.io> @ Lightbend <http://typesafe.com> > <http://lightbend.com> > > On 6 April 2016 at 12:03:27, xiaog zh (zhxi...@gmail.com <javascript:>) > wrote: > > hi, > I use `Http().singleRequest()` to contact with a upstream API server, > and the server returns 404 all the time (when query non exists entities). > And suddenly, roughly about 3 ~ 4 round request-response trips, I get such > log with stack trace not formatted. And after this log, my requests to the > server never returns(resulting timeout). I guess the streaming > infrastructure is broken. Could somebody explain this? > > > DEBUG - akka.actor.RepointableActorRef - Aborting tcp connection because > of upstream failure: No elements passed in the last 1 minute. > > akka.stream.impl.Timers$IdleTimeoutBidi$$anon$4.onTimer(Timers.scala:147) > > akka.stream.stage.TimerGraphStageLogic. > akka$stream$stage$TimerGraphStageLogic$$onInternalTimer(GraphStage.scala: > 1124) > > akka.stream.stage. > TimerGraphStageLogic$$anonfun$akka$stream$stage$TimerGraphStageLogic$$getTimerAsyncCallback$1 > .apply(GraphStage.scala:1113) > > akka.stream.stage. > TimerGraphStageLogic$$anonfun$akka$stream$stage$TimerGraphStageLogic$$getTimerAsyncCallback$1 > .apply(GraphStage.scala:1113) > > akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter. > scala:569) > > akka.stream.impl.fusing.GraphInterpreterShell.receive( > ActorGraphInterpreter.scala:417) > > akka.stream.impl.fusing.ActorGraphInterpreter. > akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent( > ActorGraphInterpreter.scala:593) > > akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1. > applyOrElse(ActorGraphInterpreter.scala:604) > > akka.actor.Actor$class.aroundReceive(Actor.scala:482) > > akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive( > ActorGraphInterpreter.scala:519) > > akka.actor.ActorCell.receiveMessage(ActorCell.scala:526) > > akka.actor.ActorCell.invoke(ActorCell.scala:495) > > akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) > > akka.dispatch.Mailbox.run(Mailbox.scala:224) > > akka.dispatch.Mailbox.exec(Mailbox.scala:234) > > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java > :1339) > > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread. > java:107) > > -- > >>>>>>>>>> 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 akka-user+...@googlegroups.com <javascript:>. > To post to this group, send email to akka...@googlegroups.com > <javascript:>. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > > -- >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
