Re: [akka-user] akka.actor.ActorNotFound In Spark Streaming on Mesos (using ssc.actorStream)

If the actor system name has changed to sparkExecutor the actor selection using sparkDriver is not valid any more. What happens if you change the actor selection path? /Patrik On Wed, Jan 7, 2015 at 2:52 PM, Christophe Billiard < christophe.billi...@gmail.com> wrote: > Hi all, > > I have an acto

Re: [akka-user] Re: File based mailbox - Files under _mb location grows large consistently without getting cleared

Durable MBs are no longer supported. I recommend you to switch to Akka Persistence (perhaps with the LevelDB Journal, since it is closest to your durable MB). Is that possible? On Fri, Jan 9, 2015 at 7:27 AM, wrote: > I could see a similar issue was discussed in the below thread from Daniele. >

Re: [akka-user] Akka Persistence on the Query Side: The Conclusion

That is a great point Greg. On Wed, Jan 7, 2015 at 10:15 PM, Greg Young wrote: > "The consistency of the query model should be achieved as soon as > possible and close to real-time." > > It really depends on the domain. I have worked in many situations > where the data in question would be perfe

[akka-user] Re: File based mailbox - Files under _mb location grows large consistently without getting cleared

I could see a similar issue was discussed in the below thread from Daniele. https://groups.google.com/forum/#!searchin/akka-user/file$20based/akka-user/0Yt78n73a4o But, I couldn't find an answer there for the files growing big issue. On Friday, January 9, 2015 at 11:56:39 AM UTC+5:30, araman...

[akka-user] File based mailbox - Files under _mb location grows large consistently without getting cleared

Hi Akka Users, I have a problem with actors using the file based mailbox. The size of mailbox files under _mb folder keeps on increasing as the number of messages are processed. All messages are getting processed fine in the system, so shouldn't they be removed from the file when completed? I f

[akka-user] Re: Unordered merge of 2..n streams created by groupBy

Akka maintainers, how does this solution look (see mentioned gist in quoted text)? I'll probably need some degree of guidance, but this solution is working well for my needs; I'm happy to produce a pull-request for Akka streams to implement FlattenStrategy.mergeUnordered. On Wednesday, January

Re: [akka-user] Not loosing message due to remote actor unavailable.

Sorry for awakening this old thread... Is it really the case that there is all this fancy supervision architecture, and then a remote actor that has gone non-responsive, needs to be handled outside of the supervision hierarchy alltogether? was it considered enabling supervision to work such tha

[akka-user] Re: Actor lifecycle with regard to unresponsive actors

Thanks for the reminder. The Phi Accrual Failure Detector is nice, although it is unfortunate that tuning the threshold is an art (see mention of EC2 in http://doc.akka.io/docs/akka/snapshot/scala/remoting.html

Re: [akka-user] Getting strange error 2.4-Snapshot with stream+http 1.0-M2

Yessir. That was the issue. Rebuilt against 2.3.x and its stable. Thanks! On Wednesday, January 7, 2015 2:42:56 AM UTC-6, drewhk wrote: > > Hi, > > Streams is compiled against Akka 2.3.x which is not guaranteed to be > binary compatible with 2.4. I expect that the above code to work with Akka

[akka-user] Re: Actor lifecycle with regard to unresponsive actors

Your first step would probably be the documentation at : http://doc.akka.io/docs/akka/snapshot/scala/remoting.html In particular the sections - "Lifecycle and Failure Recovery Model" You could also have a look at http://doc.akka.io/docs/akka/snapshot/general/configuration.html and any of the s

[akka-user] akka-http respond with result of an actor call (java-api)

Hello, I'm playing arround with the Java-API of the new akka-http server and I would like to reply to a request with the result of an asynchronous actor (i.e. some kind of DB-query). I would have expected that I somehow can pass a Future to the context.complete or a "Future" entity. But this se

[akka-user] Re: is this a sensible problem for persistence?

Hmm - on reading other threads and reflection I think I may have the wrong model here. The information about the ETA is possibly not something that should be persisted. It's not hard data. And perhaps my parcel should be split between a persisting actor (still need 1m of them) and some sort of

[akka-user] support for akka persistent plugins

Which, if any, of the main target plugins (Cassandra, etc) are supported by Typesafe or commercially via other parties? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Sear

[akka-user] is this a sensible problem for perdistence?

Hi I'm looking at modelling a large parcel delivery system with approximately 300k - 1m parcels per day depending on time of year. Each of those parcels has its own life cycle from assignment to a trip through eventual delivery. If parcels are on a route, then, for example, a delivery event at p

[akka-user] Actor lifecycle with regard to unresponsive actors

Hi, I have read this other thread about the case of a remote being unavailable . I assume it still applies to the most current version (?). My question is, how do both the supervision system (the part that's above user c

[akka-user] Re: Akka Http Client - User-Agent header

Hi Marcin, the user agent string is a config property and configured here . Cheers André On Wednesday, January 7, 2015 9:14:23 PM UTC+1, Marcin Gosk wrote: > > Hey guys, is it possible t