Hi Martin,
To answer your previous question nothing happens if I restart my
application. The persisted files don't get deleted. I also tested the code
with a smaller size message and was able to see the same problem.
I have created a very simple runnable application that uses
PersistenceChannel to send messages to a IOWorker that immediately confirms
the message. As stated above; this examples shows how the journal space
keeps growing over time even though the message gets confirmed and
should be deleted after a while asynchronously.
The code is placed
here<https://github.com/manasdebashiskar/akkapersistenceExample>
.
Once again thanks for your help. I am sure it is something that I am doing
wrong because of which only I see this and no-one else seems to be
complaining about.
...Manas
On Friday, March 21, 2014 3:49:17 AM UTC-4, Martin Krasser wrote:
>
>
> 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.
>>>
>>>
>>> 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 ConfirmablePersistent message.
>>>>
>>>> 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
>>> >>>>>>>>>> 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.
>>>
>>>
>>> --
>>> 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.
