2015-03-31 11 views
7

लोड नहीं किया जा सकता है, मैं अपाचे बेंच टूल का उपयोग करके एक अभिनेता मॉडल के आधार पर अपने स्प्रे http क्लाइंट का परीक्षण लोड करने का प्रयास कर रहा हूं। प्रदर्शन बहुत अच्छा नहीं है। और भी, जब मैं समेकन स्तर को लगभग 200-300 तक बढ़ाता हूं, तो मुझे लॉगर्स से संबंधित कई त्रुटियां दिखाई देती हैं।अक्का कॉन्फ़िगरेशन अपवाद: निर्दिष्ट लॉगर

कोड स्निपेट

val result = for { 
     response <- GlobalObject.io.ask(HttpRequest(GET,URL)).mapTo[spray.http.HttpResponse] 
    } yield response 
    result Oncomplete{ 
    case Success(response) => doSomething 
    } 

पूर्ण स्टैक ट्रेस: ​​

[info] [WARN] [03/31/2015 14:31:52.580] [squbs-akka.actor.default-dispatcher-26] [EventStream(akka://hcp-client)] Logger log1-Logging$DefaultLogger did not respond within Timeout(5000 milliseconds) to InitializeLogger(bus) 
[error] error while starting up loggers 
[error] akka.ConfigurationException: Logger specified in config can't be loaded [akka.event.Logging$DefaultLogger] due to [akka.event.Logging$LoggerInitializationException: Logger log1-Logging$DefaultLogger did not respond with LoggerInitialized, sent instead [TIMEOUT]] 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$1.applyOrElse(Logging.scala:116) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$1.applyOrElse(Logging.scala:115) 
[error]   at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) 
[error]   at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:215) 
[error]   at scala.util.Try$.apply(Try.scala:191) 
[error]   at scala.util.Failure.recover(Try.scala:215) 
[error]   at akka.event.LoggingBus$$anonfun$4.apply(Logging.scala:115) 
[error]   at akka.event.LoggingBus$$anonfun$4.apply(Logging.scala:110) 
[error]   at scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:728) 
[error]   at scala.collection.Iterator$class.foreach(Iterator.scala:750) 
[error]   at scala.collection.AbstractIterator.foreach(Iterator.scala:1202) 
[error]   at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) 
[error]   at scala.collection.AbstractIterable.foreach(Iterable.scala:54) 
[error]   at scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:727) 
[error]   at akka.event.LoggingBus$class.startDefaultLoggers(Logging.scala:110) 
[error]   at akka.event.EventStream.startDefaultLoggers(EventStream.scala:26) 
[error]   at akka.actor.LocalActorRefProvider.init(ActorRefProvider.scala:622) 
[error]   at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:619) 
[error]   at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:616) 
[error]   at akka.actor.ActorSystemImpl._start(ActorSystem.scala:616) 
[error]   at akka.actor.ActorSystemImpl.start(ActorSystem.scala:633) 
[error]   at akka.actor.ActorSystem$.apply(ActorSystem.scala:142) 
[error]   at akka.actor.ActorSystem$.apply(ActorSystem.scala:109) 
[error]   at com.paypal.vyasa.persistors.KafkaStorage.<init>(KafkaStorage.scala:40) 
[error]   at sun.reflect.GeneratedConstructorAccessor22.newInstance(Unknown Source) 
[error]   at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
[error]   at java.lang.reflect.Constructor.newInstance(Constructor.java:408) 
[error]   at akka.util.Reflect$.instantiate(Reflect.scala:66) 
[error]   at akka.actor.ArgsReflectConstructor.produce(Props.scala:352) 
[error]   at akka.actor.Props.newActor(Props.scala:252) 
[error]   at akka.actor.ActorCell.newActor(ActorCell.scala:552) 
[error]   at akka.actor.ActorCell.create(ActorCell.scala:578) 
[error]   at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) 
[error]   at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) 
[error]   at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279) 
[error]   at akka.dispatch.Mailbox.run(Mailbox.scala:220) 
[error]   at akka.dispatch.Mailbox.exec(Mailbox.scala:231) 
[error]   at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
[error]   at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 
[error]   at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
[error]   at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 
[error] Caused by: akka.event.Logging$LoggerInitializationException: Logger log1-Logging$DefaultLogger did not respond with LoggerInitialized, sent instead [TIMEOUT] 
[error]   at akka.event.LoggingBus$class.akka$event$LoggingBus$$addLogger(Logging.scala:185) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$4.apply(Logging.scala:114) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$4.apply(Logging.scala:113) 

मैं वेब खोज की, लेकिन लगता है त्रुटि अद्वितीय है। कोई भी किसी को जाता है? इसके अलावा किसी भी लीड पर प्रदर्शन कैसे किया जा सकता है? अनुरोधों की कुल संख्या लगभग 15 प्रति सेकंड थ्रॉटल लगती है।

उत्तर

8

यह त्रुटि पहले से ही वेब में उल्लेख किया गया है:

https://groups.google.com/forum/#!topic/akka-user/nng-bb2IZFA

इसका मतलब है कि अभिनेताओं में से एक (log1-लॉग इन) समय में जवाब नहीं दिया। आप logger-startup-timeout सेटिंग का उपयोग कर समय समाप्ति को बढ़ा सकते हैं:

  • हो सकता है आप चुना है बहुत कम है (या उच्च) पूल क्षमता
  • :

    # Loggers are created and registered synchronously during ActorSystem 
    # start-up, and since they are actors, this timeout is used to bound the 
    # waiting time 
    logger-startup-timeout = 5s 
    

    संभव कारण है कि यह हो सकता है निष्पादक सेवा (पूल) विन्यास है

  • हो सकता है कि आप पूल का उपयोग कर रहे हों, जो धागे भुखमरी की समस्या से प्रभावित हो सकता है - कोई भी पूल जो प्रबंधित अवरोधन (नियमित रूप से निर्मित और गतिशील पूल सहित) का समर्थन नहीं करता है। यह कांटा-जोड़-पूल (जो अक्का में डिफ़ॉल्ट रूप से उपयोग)
0

यह शायद LOGBACK-1221, जो Logback 1.1.10 में तय किया गया था की वजह से है का उपयोग करके हल किया जा सकता। यदि आप लॉगबैक के पहले संस्करण का उपयोग कर रहे हैं, तो समाधान 1.1.10 या बाद में अपडेट करने के लिए है।

संबंधित मुद्दे