Hi guys, this is my testing flow:
1. Start Node A with roles "seed" and "master", also create a ShardRegion
Proxy:
val shardProxy = ClusterSharding(system).startProxy(
typeName = WorkerActor.shardName,
role = Some("worker"),
extractEntityId = WorkerActor.idExtractor,
extractShardId = WorkerActorshardResolver)
2. Start Node B with role "worker", create a shard region on this node:
val settings = ClusterShardingSettings(system)
ClusterSharding(system).start(
typeName = WorkerActor.shardName,
entityProps = WorkerActor.props(),
settings = settings,
extractEntityId = WorkerActor.idExtractor,
extractShardId = WorkerActor.shardResolver,
allocationStrategy = new
LeastShardAllocationStrategy(settings.tuningParameters.leastShardAllocationRebalanceThreshold,
0),
PoisonPill)
I can see that both nodes will go to UP status. But I saw a lot of this
message on both nodes:
[akka://am-ae-cluster/system/sharding/WorkerCoordinator/singleton/coordinator]
Message [akka.cluster.sharding.ShardCoordinator$Internal$RegisterProxy]
from
Actor[akka.tcp://[email protected]:1600/system/sharding/Worker#-206434238]
to
Actor[akka://am-ae-cluster/system/sharding/WorkerCoordinator/singleton/coordinator]
was not delivered.
And because of this, I can't send any messages to the shard proxy. If I
create a ShardRegion on node A instead of the proxy, the system will work.
So am I wrong at something or this is a bug?
Thanks
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
