Aaronontheweb
commented
2 years ago HOCON configuration for this reproduction:
akka{
cluster.sharding{
# use separate journal implementations for Akka.Cluster.Sharding
journal-plugin-id = akka.persistence.journal.sharding
snapshot-plugin-id = akka.persistence.snapshot-store.sharding
state-store-mode = persistence
remember-entities-store = eventsourced
remember-entities = on
passivate-idle-entity-after = off
fail-on-invalid-entity-state-transition = on
}
persistence{
journal{
sharding{
# qualified type name of the SQL Server persistence journal actor
class = "Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer"
# connection string used for database access
connection-string = ""
# SQL server table corresponding with persistent journal
table-name = ShardingEventJournal
metadata-table-name = ShardingMetadata
# should corresponding journal table be initialized automatically
auto-initialize = on
event-adapters {
tagger = "SqlSharding.Shared.MessageTagger, SqlSharding.Shared"
coordinator-migration = "Akka.Cluster.Sharding.OldCoordinatorStateMigrationEventAdapter, Akka.Cluster.Sharding"
}
event-adapter-bindings = {
"System.Object" = tagger
"Akka.Cluster.Sharding.ShardCoordinator+IDomainEvent, Akka.Cluster.Sharding" = coordinator-migration
}
}
}
snapshot-store{
sharding{
# qualified type name of the SQL Server persistence journal actor
class = "Akka.Persistence.SqlServer.Snapshot.SqlServerSnapshotStore, Akka.Persistence.SqlServer"
# connection string used for database access
connection-string = ""
# SQL server table corresponding with persistent journal
table-name = ShardingSnapshotStore
# should corresponding journal table be initialized automatically
auto-initialize = on
}
}
}
}This is supposed to be stage 1 of the Akka.NET v1.5 migration.
Arkatufus
Version Information Version of Akka.NET? v1.5.0-alpha1 Which Akka.NET Modules? Akka.Cluster.Sharding
Describe the bug
It looks like the Akka.Cluster.Sharding
PersistentCoordinatoris not able to correctly run its shard migration, as we see error messages like this at startup:And in addition to that, the Akka.Persistence.SqlServer journal returns no results for
SM- indicating that the migration of previous remember-entities data was executed:To Reproduce
Reproduction instructions and data available here: https://github.com/petabridge/akkadotnet-code-samples/pull/112
Expected behavior
All remembered-entities should start automatically.
Actual behavior
None do.
Additional context
I used a
pbm actor hierarchy -s akka://SqlSharding/ -d 6command to do a dump of the entire actor hierarchy after the sharding system started correctly and here's what I found:This verifies that none of the remembered entities or shards started correctly.