On 16.05.14 09:04, Raymond Tay wrote:
Hi Martin,
Thank you for the guide. Am testing it out with the HBase plugin you
wrote
this was written by Konrad.
as well as the shared levelDB journaling plugin.
Have fun!
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
<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
<http://doc.akka.io/docs/akka/current/additional/faq.html>
>>>>>>>>>> Search the archives:
https://groups.google.com/group/akka-user
<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
<http://groups.google.com/group/akka-user>.
For more options, visit https://groups.google.com/d/optout
<https://groups.google.com/d/optout>.
--
Martin Krasser
blog:http://krasserm.blogspot.com
code:http://github.com/krasserm
twitter:http://twitter.com/mrt1nz
--
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.
