fix sharding recovery (#5863)

akkadotnet · Apr 21, 2022 · 9bbb68f · 9bbb68f
1 parent 8e7f021
commit 9bbb68f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ib/cluster/Akka.Cluster.Sharding/Internal/EventSourcedRememberEntitiesCoordinatorStore.cs b/...ib/cluster/Akka.Cluster.Sharding/Internal/EventSourcedRememberEntitiesCoordinatorStore.cs
@@ -120,7 +120,7 @@ protected override bool ReceiveRecover(object message)
                     _shards.UnionWith(state.Shards.Keys.Union(state.UnallocatedShards));
                     return true;
                 case SnapshotOffer offer when (offer.Snapshot is State state):
-                    _shards.Union(state.Shards);
+                    _shards.UnionWith(state.Shards);
                     _writtenMarker = state.WrittenMigrationMarker;
                     return true;
                 case RecoveryCompleted _: