On 19.03.14 15:38, Manas Kar wrote:
Hi Martin,
I have a process that is running since last Sunday evening using the
above code base(Given here
<http://stackoverflow.com/questions/22315418/akka-persistentchannel-does-not-delete-message-from-journal-upon-confirm>)
. The journal space has grown to be around 24 GB so far. I am still
continuing my run to see when the compaction will happen and the
"marked deleted" messages will be physically deleted.
What happens when you restart the application?
The only way my code is different than your example is that my message
has the size of 8 MB. Could that be playing some role?
No.
Thanks
Manas
On Wednesday, March 12, 2014 1:09:38 PM UTC-4, Manas Kar wrote:
Thanks Martin.
That explains what I am seeing.
On Wednesday, March 12, 2014 12:15:15 PM UTC-4, Martin Krasser wrote:
On 11.03.14 19:22, Manas Kar wrote:
Hi Martin,
I observed something that kind of contradicts my previous
statement. It would be correct to say that the size of
journal folder is approximately half the size of SumOf(messages).
My messages don't get replayed after the configurable times
from the channels. But the journal's are not physically
deleted amounting to large disk usage.
Please find my modified scala code that follows the example
you provided and still leaves residues in journal folder.
LevelDB doesn't delete entries immediately, it rather marks
them as deleted and physically deletes them during
compactions. Details at
http://leveldb.googlecode.com/svn/trunk/doc/impl.html
<http://leveldb.googlecode.com/svn/trunk/doc/impl.html>.
Thanks
...Manas
On Tuesday, March 11, 2014 2:19:51 AM UTC-4, Manas Kar wrote:
Hi,
I am very excited about the latest and the biggest
feature of Akka2.3.0 that is Persistence.
I have posted a question about Akka persistentChannel
here.
<http://stackoverflow.com/questions/22315418/akka-persistentchannel-does-not-delete-message-from-journal-upon-confirm>
Basically I have a persistentChannel that sends some
IOWork to a destination actor. Destination actor tries to
do the work and when successfully completes the work or
the deadline has no time left it sends a "confirm" on
the ConfirmablePersistentmessage.
My expectation after reading the documentation was that
my message will be deleted from the journal after I
"confirm" the message but it does not. Am I doing
something wrong here? my requirement is simple persist
the message and delete it after the corresponding IO work
is done for the message.
Please help.
...Manas
--
>>>>>>>>>> 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].
To post to this group, send email to [email protected].
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.
