[akka-user] Cluster sharding with Persistence: Failing require statement,

I have a 2 node akka cluster. I am trying to run a persistent actor with cluster sharding. When the ShardCoordinator starts up, it is throwing an IllegalArgumentException. After digging through the source code, I found it to be a require statement in ClusterSharding.scala case ShardHomeAllocat

Re: [akka-user] Cluster sharding with Persistence: Failing require statement,

What version of Akka are you using? Can you run it with debug log level and share those logs? The logging during recovery should tell us what is going on. My guess is that you have ended up with inconsistent data, which may happen if you split the cluster in two separate clusters and the coordinat

Re: [akka-user] Cluster sharding with Persistence: Failing require statement,

I ran into the same issue in a staging environment with Akka 2.3.12 and Cassandra as persistent backend. I did what Patrik suggested and believe it is triggered by corrupted data by having started a second cluster for a short period of time (2 minutes). I am now trying to repair the data by del

Re: [akka-user] Cluster sharding with Persistence: Failing require statement,

Update: I was able to recover after deleting some messages. I also found this relevant issue https://github.com/akka/akka/issues/17955 I deleted the events persisted by the second cluster and all persistent actors affected by it (that's probably optional and depends on your data model), but wha

Re: [akka-user] Cluster sharding with Persistence: Failing require statement,

Thanks for the update. For reference: Removal of Internal Cluster Sharding Data /Patrik On Thu, Oct 29, 2015 at 11:49 PM, Stefan Bleibinhaus < stefan.bleibinh...@gmail.com> wrote: > Update: