IllegalStateException in cassandra journal

All,

I am recently observing the following exception while starting some persistent actors which i havent seen before I upgraded to Akka 2.5.21 and cassandra 0.93. It seems to happen when the system under higher load. Has anybody observed anything similar, or has an idea where i could look in doing differently ? This is a plain john-doe actor doing nothing special, but i see that for any sort of persistent actor in the system, not only this one.
We are java8, if that makes a difference, but i dont see why it would…

java.lang.IllegalStateException: Watch(Actor[akka://GlueService_dev-local_global/system/glue-cassandra-journal/tagWrites#-479231915], Actor[akka://GlueService_dev-local_global/system/sharding/GlueServiceRegion_canoe_1/ShardOf-example.com/glueService/glue/service/dependantsManager/example.com:additional1:dependant:shared:transaction-Transaction179@testexportportfolioperformance_e3ea1d3d-a7e6-439a-94eb-52507ad19400#-112428511]) termination message was not overwritten from [Some(PersistentActorTerminated(example.com:additional1:dependant:shared:transaction-Transaction-7878-@testcreatetransactionsfromcsvperformance-a5620399-ba15-4a87-83a3-e1d67da834b0,Actor[akka://GlueService_dev-local_global/system/sharding/GlueServiceRegion_canoe_1/ShardOf-example.com/glueService/glue/service/dependantsManager/example.com:additional1:dependant:shared:transaction-Transaction179@testexportportfolioperformance_e3ea1d3d-a7e6-439a-94eb-52507ad19400#-112428511]))] to [Some(PersistentActorTerminated(example.com:additional1:dependant:shared:transaction-Transaction9520@testcreatefxforwardtransactionperformancestream-8bb6f451-5147-4288-a493-206767327263,Actor[akka://GlueService_dev-local_global/system/sharding/GlueServiceRegion_canoe_1/ShardOf-example.com/glueService/glue/service/dependantsManager/example.com:additional1:dependant:shared:transaction-Transaction179@testexportportfolioperformance_e3ea1d3d-a7e6-439a-94eb-52507ad19400#-112428511]))]. If this was intended, unwatch first before using watch / watchWith with another message.

Any clue would be much appreciated
Olivier

That looks like a bug, could you raise an issue with some logs at GitHub - akka/akka-persistence-cassandra: A replicated Akka Persistence journal backed by Apache Cassandra ?

Thanks for confirming, i will raise the bug.

Olivier

Can you please post here the issue for easier tracking :slight_smile:

Edit: I’ve found it: https://github.com/akka/akka-persistence-cassandra/issues/444