Hi,
Turns out there was a bug in our homebrew jdbc-snapshot implementation.
The loaded SelectedSnapshot was populated with Option(state) instead of
just the state, so the following lines in ShardCoordinator was not executed:
case SnapshotOffer(_, state: State) =>
log.debug("receiveRecover SnapshotOffer {}", state)
persistentState = state
The snapshot was therefor never applied, so when it started receiving
events with sequenceNr after the snapshot, it blew up.
Thanks a lot for helping me in the right direction.
Best regards,
Morten Kjetland
On Wed, Aug 6, 2014 at 2:12 PM, Morten Kjetland <[email protected]> wrote:
> Thanks the response,
>
> We are using a homebrew jdbc journal.
>
> I checked the journal and ShardRegionProxyRegistered is written to it.
> But I was unable to reproduce the problem now.
> It might be a problem related to snapshoting in combination with a bug in
> our jdbc journal.
> I'll try to reproduce it later and check the db again.
>
> I just saw that https://github.com/dnvriend/akka-persistence-jdbc was
> worked on during the summer, so I'll try to use that one instead of our
> own, and see if the problem goes away.
>
> Best regards,
> Morten Kjetland
>
>
> On Wed, Aug 6, 2014 at 12:40 PM, Konrad Malawski <[email protected]>
> wrote:
>
>> Hi Morten,
>> thanks for reporting!
>> Which journal plugin are you using?
>>
>> It looks like during replay it gets an ShardHomeAllocated without getting
>> ShardRegionProxyRegistered first - which makes it blow up (we must first
>> register, then allocate the shard).
>>
>> One reason could be that the persist of ShardRegionProxyRegistered never
>> succeeded...?
>> Would you be able to verify if your journal contains such these events
>> (or if SRPR is missing)?
>> It would be great to track down to the root of this problem. It *could*
>> be a bug on our side, but hard to pinpoint exactly yet.
>>
>> --
>> 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.
>>
>
>
--
>>>>>>>>>> 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.
