diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala index c724cb2a93..eefea65243 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala @@ -1422,7 +1422,7 @@ private[akka] class DDataShardCoordinator( if (shardIds.nonEmpty) { val newUnallocatedShards = state.unallocatedShards.union(shardIds.diff(state.shards.keySet)) state = state.copy(unallocatedShards = newUnallocatedShards) - newUnallocatedShards.foreach { self ! GetShardHome(_) } + allocateShardHomesForRememberEntities() } timers.cancel(RememberEntitiesTimeoutKey)