This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 7f3b330705 Initialize DistributedData extension from
ExternalShardAllocationStrategy eagerly (#2923)
7f3b330705 is described below
commit 7f3b330705fcee641ddd2c5306e8bdef592ae742
Author: Philippus Baalman <[email protected]>
AuthorDate: Wed Apr 29 12:10:27 2026 +0200
Initialize DistributedData extension from ExternalShardAllocationStrategy
eagerly (#2923)
---
.../cluster/sharding/external/ExternalShardAllocationStrategy.scala | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategy.scala
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategy.scala
index 5c1333cca4..847c867d5b 100644
---
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategy.scala
+++
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategy.scala
@@ -133,6 +133,11 @@ class ExternalShardAllocationStrategy(systemProvider:
ClassicActorSystemProvider
private var shardState: ActorRef = _
+ // Eagerly initialize the DistributedData extension on all nodes. Otherwise,
if not used for other things,
+ // the DistributedData Replicator is started via the DDataStateActor by the
shard coordinator on one node,
+ // but not on other nodes.
+ DistributedData(systemProvider)
+
private[pekko] def createShardStateActor(): ActorRef = {
system
.asInstanceOf[ExtendedActorSystem]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
