Hi Martin, Thank you for the guide. Am testing it out with the HBase plugin you wrote as well as the shared levelDB journaling plugin.
Will post updates soon. On Friday, May 16, 2014 2:53:45 PM UTC+8, Martin Krasser wrote: > > Hi Raymond, > > seems that two processes/JVMs access the same journal files on disk, which > is not allowed. Either use one of the distributed journals (see Akka > community projects) or use a shared LevelDB > journal<http://doc.akka.io/docs/akka/2.3.2/scala/persistence.html#shared-leveldb-journal>for > testing purposes. > > Cheers, > Martin > > On 16.05.14 08:41, Raymond Tay wrote: > > Hi akka devs, > > I have a scenario where a `akka-cluster-2.3.2` is running > `akka-persistence-2.3.2` and 2 nodes participate. Next, we create two > _distinct_ sets of (processor, view, actor, channel) to represent two > domain objects in our application. Next, we have the two data sets write > stuff to the `journal` configured locally using `levelDB`. > > Then, when one processor proceeds to write to the storage and another > processor attempts to write to the same storage there's a failure condition > triggered by the second processor (attempting the write) because the first > processor has acquired the lock. (This is evident after reading through the > source code of `levelDB`) > > Kindly see the detailed lock below > >> ERROR] [05/16/2014 13:19:55.242] >> [TrailingHammer-akka.actor.default-dispatcher-18] >> [akka://TrailingHammer/system/journal] Unable to acquire lock on >> '/Users/raymondtay/temp/bamboo-management-0.1-SNAPSHOT/journal/LOCK' >> akka.actor.ActorInitializationException: exception during creation >> at akka.actor.ActorInitializationException$.apply(Actor.scala:164) >> at akka.actor.ActorCell.create(ActorCell.scala:596) >> at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) >> at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) >> at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) >> at akka.dispatch.Mailbox.run(Mailbox.scala:219) >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >> at java.lang.Thread.run(Thread.java:722) >> Caused by: java.io.IOException: Unable to acquire lock on >> '/Users/raymondtay/temp/bamboo-management-0.1-SNAPSHOT/journal/LOCK' >> at org.iq80.leveldb.impl.DbLock.<init>(DbLock.java:55) >> at org.iq80.leveldb.impl.DbImpl.<init>(DbImpl.java:167) >> at org.iq80.leveldb.impl.Iq80DBFactory.open(Iq80DBFactory.java:59) >> at >> akka.persistence.journal.leveldb.LeveldbStore$class.preStart(LeveldbStore.scala:114) >> at >> akka.persistence.journal.leveldb.LeveldbJournal.preStart(LeveldbJournal.scala:20) >> at akka.actor.Actor$class.aroundPreStart(Actor.scala:470) >> at >> akka.persistence.journal.leveldb.LeveldbJournal.aroundPreStart(LeveldbJournal.scala:20) >> at akka.actor.ActorCell.create(ActorCell.scala:580) >> ... 7 more > > > I know the scenario is probably an outlier but i ran along with it > anyway, the real question i have is whether this is a bug ? or some kind of > outlier situation not catered for ? > > I have opened this as a ticket: https://github.com/akka/akka/issues/15211 > > > br, > Raymond > -- > >>>>>>>>>> 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > > > -- > Martin Krasser > > blog: http://krasserm.blogspot.com > code: http://github.com/krasserm > twitter: http://twitter.com/mrt1nz > > -- >>>>>>>>>> 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.
