As usual, the solution is trivial. I can confirm that changing persist => persistAsync solves my performance problems.
Thanks a lot, Konrad. On Thursday, July 17, 2014 2:15:46 AM UTC-7, Konrad Malawski wrote: > > Hi Mike, > The problem is you have not performed a 1:1 migration, instead you ended > up using what was previously known as EventsourcedProcessor, but you > expected to use "the new Processor". > > Using persist + PersistentActor, which is equivalent to the previous > persist in EventsourcedProcessor. > Since you are migrating from persist + Processor, you should migrate to > it’s equivalent: persistAsync. > > Please check the migration guide where this is explained: > http://doc.akka.io/docs/akka/2.3.4/project/migration-guide-persistence-experimental-2.3.x-2.4.x.html#removed-processor-in-favour-of-extending-persistentactor-with-persistasync > > PersistentActor + persistAsync in 2.3.4 == Processor in 2.3.3. > PersistentActor + persist in 2.3.4 == EventsourcedProcessor in 2.3.3, it > will be by definition slower than persistAsync, because of stronger > guarantees it delivers. > > > Here are the benchmark results (Intel(R) Core(TM) i7-4850HQ CPU @ 2.30GHz, > LevelDB), from the JMH bench I linked to previously, as you’ll notice > PersistentActor#persistAsync is on par with Processor#persist: > > [info] Benchmark > Mode Samples Score Score error Units > [info] > a.p.PersistentActorThroughputBenchmark.actor_*normalActor_reply_baseline* > thrpt 10 147567.305 4617.027 ops/s > [info] a.p.PersistentActorThroughputBenchmark.persistentActor_noPersist_reply > thrpt 10 147099.384 6547.412 ops/s > [info] a.p.PersistentActorThroughputBenchmark.processor_noPersist_reply > thrpt 10 45720.023 1850.406 > ops/s[info] > a.p.PersistentActorThroughputBenchmark.persistentActor_persistAsync_replyRightOnCommandReceive > thrpt 10 116179.339 41959.652 ops/s > [info] > a.p.PersistentActorThroughputBenchmark.*persistentActor_persistAsync_reply > thrpt 10 28391.199 647.556 ops/s* > [info] a.p.PersistentActorThroughputBenchmark.*processor_persist_reply* > * thrpt 10 26594.156 586.717 > ops/s > > *[info] a.p.PersistentActorThroughputBenchmark.persistentActor_persist_reply > thrpt 10 4696.254 104.952 ops/s > > > > Change your code to use persistAsync && happy hakking! > > -- > Cheers, > Konrad 'ktoso' Malawski > hAkker @ Typesafe > > <http://typesafe.com> > -- >>>>>>>>>> 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
