Do you start it on all nodes? ClusterSharding(system).start(...) On Tue, Dec 20, 2016 at 4:01 PM, Víctor Martínez <[email protected]> wrote:
> I turn on the logs in both nodes but just the younger print information. > The logs is: > > [DEBUG] [12/20/2016 14:54:48.913] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka.tcp://[email protected]:2551/system/IO-TCP/selectors/$a/0] > New connection accepted > [DEBUG] [12/20/2016 14:54:48.925] > [ClusterSystem-akka.actor.default-dispatcher-20] > [akka://ClusterSystem/system/IO-TCP/selectors/$a/1] started (akka.io. > TcpIncomingConnection@5dffe619) > [DEBUG] [12/20/2016 14:54:48.942] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/system/IO-TCP/selectors/$a/1] now watched by > Actor[akka://ClusterSystem/system/IO-TCP/selectors/$a#1676264200] > [DEBUG] [12/20/2016 14:54:48.942] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/system/IO-TCP/selectors/$a] now supervising > Actor[akka://ClusterSystem/system/IO-TCP/selectors/$a/1#874469516] > [DEBUG] [12/20/2016 14:54:48.986] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka://ClusterSystem/user/StreamSupervisor-0] now supervising > Actor[akka://ClusterSystem/user/StreamSupervisor-0/flow- > 1-0-unknown-operation#-1972996806] > [DEBUG] [12/20/2016 14:54:48.988] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/system/IO-TCP/selectors/$a/1] now watched by > Actor[akka://ClusterSystem/user/StreamSupervisor-0/$$b#1663506069] > [DEBUG] [12/20/2016 14:54:49.004] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka://ClusterSystem/user/StreamSupervisor-0/flow-1-0-unknown-operation] > started (akka.stream.impl.fusing.ActorGraphInterpreter@34ecd16b) > [DEBUG] [12/20/2016 14:54:49.126] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/user] now supervising Actor[akka://ClusterSystem/ > user/notification-ca15d87e-d5e1-4441-a646-9d0c6656892f#-368201891] > [DEBUG] [12/20/2016 14:54:49.133] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/user/notification-ca15d87e-d5e1-4441-a646-9d0c6656892f] > started (com.test.kernel.scala.util.NotificationManager@22ff09e6) > [DEBUG] [12/20/2016 14:54:49.137] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/user] now supervising Actor[akka://ClusterSystem/ > user/$a#1148302915] > [DEBUG] [12/20/2016 14:54:49.140] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/user/$a] started (com.test.kernel.scala. > application.CommandBus$CommandBusSupervisor@75e9f82c) > [DEBUG] [12/20/2016 14:54:49.151] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.tcp://[email protected]:2551/user/$a] > [CommandBusSupervisor]==========>>>>Trying message: [<function1>] > [DEBUG] [12/20/2016 14:54:49.155] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/user] now supervising Actor[akka://ClusterSystem/ > user/$b#1154246638] > [DEBUG] [12/20/2016 14:54:49.156] > [ClusterSystem-akka.actor.default-dispatcher-20] > [akka://ClusterSystem/user/$b] started (com.test.kernel.scala. > application.CommandBus$CommandBusActor@14c659a1) > [DEBUG] [12/20/2016 14:54:49.159] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/user] now supervising Actor[akka://ClusterSystem/ > user/manager-35c663f9-e1d6-499f-8a3d-66c8acb70105#-55958048] > [DEBUG] [12/20/2016 14:54:49.160] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/user] now supervising Actor[akka://ClusterSystem/ > user/StreamSupervisor-4#-1322889780] > [DEBUG] [12/20/2016 14:54:49.160] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/user/StreamSupervisor-4] started (akka.stream.impl. > StreamSupervisor@299aee05) > [DEBUG] [12/20/2016 14:54:49.161] > [ClusterSystem-akka.actor.default-dispatcher-2] > [akka://ClusterSystem/user/manager-35c663f9-e1d6-499f-8a3d-66c8acb70105] > started (com.test.microservice.notification.domain.notification_type. > NotificationTypeManager@7d8848c0) > [INFO] [12/20/2016 14:54:49.349] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka.tcp://[email protected]:2551/user/$b] CommandBusActorMsg > [DEBUG] [12/20/2016 14:54:49.368] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka://ClusterSystem/system] now supervising Actor[akka://ClusterSystem/ > system/sharding#1653149723] > [DEBUG] [12/20/2016 14:54:49.369] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/sharding] started (akka.cluster.sharding. > ClusterShardingGuardian@20886c47) > [DEBUG] [12/20/2016 14:54:49.381] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/sharding] now supervising > Actor[akka://ClusterSystem/system/sharding/testCoordinator#-1082803063] > [DEBUG] [12/20/2016 14:54:49.382] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/sharding] now supervising > Actor[akka://ClusterSystem/system/sharding/test#-345684233] > [DEBUG] [12/20/2016 14:54:49.390] > [ClusterSystem-akka.actor.default-dispatcher-3] > [EventStream] subscribing Actor[akka://ClusterSystem/ > system/sharding/test#-345684233] to channel interface > akka.cluster.ClusterEvent$MemberEvent > [DEBUG] [12/20/2016 14:54:49.390] > [ClusterSystem-akka.actor.default-dispatcher-16] > [EventStreamUnsubscriber] watching Actor[akka://ClusterSystem/ > system/sharding/test#-345684233] in order to unsubscribe from EventStream > when it terminates > [DEBUG] [12/20/2016 14:54:49.392] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka://ClusterSystem/system/sharding/test] started > (akka.cluster.sharding.ShardRegion@50efa25) > [DEBUG] [12/20/2016 14:54:49.392] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka://ClusterSystem/system/sharding/test] now watched by > Actor[akka://ClusterSystem/system/eventStreamUnsubscriber-1#28733852] > [DEBUG] [12/20/2016 14:54:49.395] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka.tcp://[email protected]:2551/system/sharding/test] Request > shard [14] home > [DEBUG] [12/20/2016 14:54:49.402] > [ClusterSystem-akka.actor.default-dispatcher-14] > [akka.tcp://[email protected]:2551/system/sharding/test] > Coordinator moved from [] to [akka.tcp://[email protected]:2551] > [DEBUG] [12/20/2016 14:54:49.406] > [ClusterSystem-akka.remote.default-remote-dispatcher-6] > [akka.serialization.Serialization(akka://ClusterSystem)] Using > serializer[akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer] > for message [akka.cluster.sharding.ShardCoordinator$Internal$Register] > [DEBUG] [12/20/2016 14:54:49.410] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStream] subscribing > Actor[akka://ClusterSystem/system/sharding/testCoordinator#-1082803063] > to channel class akka.cluster.ClusterEvent$MemberExited > [DEBUG] [12/20/2016 14:54:49.411] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStream] subscribing > Actor[akka://ClusterSystem/system/sharding/testCoordinator#-1082803063] > to channel class akka.cluster.ClusterEvent$MemberRemoved > [DEBUG] [12/20/2016 14:54:49.411] > [ClusterSystem-akka.actor.default-dispatcher-3] > [EventStreamUnsubscriber] watching Actor[akka://ClusterSystem/ > system/sharding/testCoordinator#-1082803063] in order to unsubscribe from > EventStream when it terminates > [DEBUG] [12/20/2016 14:54:49.412] > [ClusterSystem-akka.actor.default-dispatcher-3] > [EventStreamUnsubscriber] watching Actor[akka://ClusterSystem/ > system/sharding/testCoordinator#-1082803063] in order to unsubscribe from > EventStream when it terminates > [DEBUG] [12/20/2016 14:54:49.416] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/cluster] now supervising > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > [DEBUG] [12/20/2016 14:54:49.417] > [ClusterSystem-akka.actor.default-dispatcher-20] > [akka://ClusterSystem/system/sharding/testCoordinator] started > (akka.cluster.singleton.ClusterSingletonManager@20027ad3) > [DEBUG] [12/20/2016 14:54:49.417] > [ClusterSystem-akka.actor.default-dispatcher-20] > [akka://ClusterSystem/system/sharding/testCoordinator] now watched by > Actor[akka://ClusterSystem/system/eventStreamUnsubscriber-1#28733852] > [DEBUG] [12/20/2016 14:54:49.418] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/system/cluster/$a] started (akka.cluster. > OnMemberStatusChangedListener@6d66eac5) > [DEBUG] [12/20/2016 14:54:49.419] > [ClusterSystem-akka.actor.default-dispatcher-3] > [EventStream] subscribing > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > to channel class akka.cluster.ClusterEvent$MemberUp > [DEBUG] [12/20/2016 14:54:49.419] > [ClusterSystem-akka.actor.default-dispatcher-3] > [EventStreamUnsubscriber] watching > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > in order to unsubscribe from EventStream when it terminates > [DEBUG] [12/20/2016 14:54:49.420] > [ClusterSystem-akka.actor.default-dispatcher-2] > [akka://ClusterSystem/system/cluster/$a] now watched by > Actor[akka://ClusterSystem/system/eventStreamUnsubscriber-1#28733852] > [DEBUG] [12/20/2016 14:54:49.425] > [ClusterSystem-akka.actor.default-dispatcher-2] > [akka://ClusterSystem/system/cluster/$a] stopped > [DEBUG] [12/20/2016 14:54:49.426] > [ClusterSystem-akka.actor.default-dispatcher-15] > [akka://ClusterSystem/system/eventStreamUnsubscriber-1] received > AutoReceiveMessage Envelope(Terminated(Actor[akka://ClusterSystem/system/ > cluster/$a#698943201]),Actor[akka://ClusterSystem/system/ > cluster/$a#698943201]) > [DEBUG] [12/20/2016 14:54:49.427] > [ClusterSystem-akka.actor.default-dispatcher-18] > [EventStream] unsubscribing > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > from all channels > [DEBUG] [12/20/2016 14:54:49.428] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStreamUnsubscriber] unsubscribe > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > from akka.event.EventStream@2f61bb7b, because it was terminated > [DEBUG] [12/20/2016 14:54:49.428] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStream] unsubscribing > Actor[akka://ClusterSystem/system/cluster/$a#698943201] > from all channels > [DEBUG] [12/20/2016 14:54:49.429] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/system/sharding/testCoordinator/$a] started > (akka.cluster.singleton.ClusterSingletonManager$ > Internal$OldestChangedBuffer@2dc2d906) > [DEBUG] [12/20/2016 14:54:49.429] > [ClusterSystem-akka.actor.default-dispatcher-18] > [EventStream] subscribing > Actor[akka://ClusterSystem/system/sharding/testCoordinator/$a#-297894587] > to channel interface akka.cluster.ClusterEvent$MemberEvent > [DEBUG] [12/20/2016 14:54:49.430] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStreamUnsubscriber] unwatching > Actor[akka://ClusterSystem/system/cluster/$a#698943201], > since has no subscriptions > [DEBUG] [12/20/2016 14:54:49.430] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStreamUnsubscriber] unwatching > Actor[akka://ClusterSystem/system/cluster/$a#698943201], > since has no subscriptions > [DEBUG] [12/20/2016 14:54:49.431] > [ClusterSystem-akka.actor.default-dispatcher-15] > [EventStreamUnsubscriber] watching Actor[akka://ClusterSystem/ > system/sharding/testCoordinator/$a#-297894587] in order to unsubscribe > from EventStream when it terminates > [DEBUG] [12/20/2016 14:54:49.436] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka://ClusterSystem/system/sharding/testCoordinator/$a] now watched by > Actor[akka://ClusterSystem/system/eventStreamUnsubscriber-1#28733852] > [DEBUG] [12/20/2016 14:54:49.437] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka://ClusterSystem/system/sharding/testCoordinator] now supervising > Actor[akka://ClusterSystem/system/sharding/testCoordinator/$a#-297894587] > [INFO] [12/20/2016 14:54:49.439] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.tcp://[email protected]:2551/system/sharding/testCoordinator] > ClusterSingletonManager state change [Start -> Younger] > [WARN] [12/20/2016 14:54:59.396] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.tcp://[email protected]:2551/system/sharding/test] Trying to > register to coordinator at [Some(ActorSelection[Anchor(akka.tcp:// > [email protected]:2551/), Path(/system/sharding/ > testCoordinator/singleton/coordinator)])], but no acknowledgement. Total > [1] buffered messages. > [WARN] [12/20/2016 14:55:01.396] > [ClusterSystem-akka.actor.default-dispatcher-4] > [akka.tcp://[email protected]:2551/system/sharding/test] Trying to > register to coordinator at [Some(ActorSelection[Anchor(akka.tcp:// > [email protected]:2551/), Path(/system/sharding/ > testCoordinator/singleton/coordinator)])], but no acknowledgement. Total > [1] buffered messages. > [WARN] [12/20/2016 14:55:03.397] > [ClusterSystem-akka.actor.default-dispatcher-20] > [akka.tcp://[email protected]:2551/system/sharding/test] Trying to > register to coordinator at [Some(ActorSelection[Anchor(akka.tcp:// > [email protected]:2551/), Path(/system/sharding/ > testCoordinator/singleton/coordinator)])], but no acknowledgement. Total > [1] buffered messages. > [WARN] [12/20/2016 14:55:05.396] > [ClusterSystem-akka.actor.default-dispatcher-3] > [akka.tcp://[email protected]:2551/system/sharding/test] Trying to > register to coordinator at [Some(ActorSelection[Anchor(akka.tcp:// > [email protected]:2551/), Path(/system/sharding/ > testCoordinator/singleton/coordinator)])], but no acknowledgement. Total > [1] buffered messages. > > El martes, 20 de diciembre de 2016, 7:07:31 (UTC-5), Patrik Nordwall > escribió: >> >> Try to turn on debug log level then. Must be something wrong with the >> setup. >> mån 19 dec. 2016 kl. 22:54 skrev Víctor Martínez <[email protected]>: >> >>> Yes, I have persistence working fine. I tried with “ddata” and >>> “persistence” with Cassandra. The node 172.19.0.2 don’t print any log. Why >>> the coordinator just startup when an actor is creating inside the node >>> .2(Oldest)? >>> >>> >>> >>> Thanks, >>> >>> >>> >>> Víctor >>> >>> El lunes, 19 de diciembre de 2016, 16:15:17 (UTC-5), Patrik Nordwall >>> escribió: >>> >>>> Any errors in the log of 172.19.0.2:2551 >>>> <http://www.google.com/url?q=http%3A%2F%2F172.19.0.2%3A2551&sa=D&sntz=1&usg=AFQjCNHKUW6bPQGb5qfAigqZsl4q2YP_pw> >>>> ? >>>> Do you have persistence working there, otherwise the coordinator will >>>> not be able to startup. >>>> >>> >>>> On Mon, Dec 19, 2016 at 3:08 PM, Víctor Martínez <[email protected]> >>>> wrote: >>>> >>>>> Hi Patrick, >>>>> >>>>> Thanks for your answer but the problem is other. Before to start the >>>>> actor it try to create the shard coordinator. The log of that is: >>>>> >>>>> >>>>> [DEBUG] [12/19/2016 14:00:18.735] [main] >>>>> [AkkaSSLConfig(akka://ClusterSystem)] >>>>> Initializing AkkaSSLConfig extension... >>>>> [DEBUG] [12/19/2016 14:00:18.738] [main] >>>>> [AkkaSSLConfig(akka://ClusterSystem)] >>>>> buildHostnameVerifier: created hostname verifier: >>>>> com.typesafe.sslconfig.ssl.DefaultHostnameVerifier@36349e29 >>>>> [DEBUG] [12/19/2016 14:00:19.174] >>>>> [ClusterSystem-akka.actor.default-dispatcher-7] >>>>> [akka.tcp://[email protected]:2551/system/IO-TCP/selectors/$a/0] >>>>> Successfully bound to /0:0:0:0:0:0:0:0:9001 >>>>> [DEBUG] [12/19/2016 14:02:38.837] >>>>> [ClusterSystem-akka.actor.default-dispatcher-7] >>>>> [akka.tcp://[email protected]:2551/system/IO-TCP/selectors/$a/0] >>>>> New connection accepted >>>>> [DEBUG] [12/19/2016 14:02:39.021] >>>>> [ClusterSystem-akka.actor.default-dispatcher-4] >>>>> [akka.tcp://[email protected]:2551/user/$a] >>>>> [CommandBusSupervisor]==========>>>>Trying message: [<function1>] >>>>> [INFO] [12/19/2016 14:02:39.185] >>>>> [ClusterSystem-akka.actor.default-dispatcher-3] >>>>> [akka.tcp://[email protected]:2551/user/$b] CommandBusActorMsg >>>>> [DEBUG] [12/19/2016 14:02:39.210] >>>>> [ClusterSystem-akka.actor.default-dispatcher-17] >>>>> [akka.tcp://[email protected]:2551/system/sharding/test] >>>>> Coordinator moved from [] to [akka.tcp://[email protected]:2551 >>>>> ] >>>>> [DEBUG] [12/19/2016 14:02:39.213] >>>>> [ClusterSystem-akka.remote.default-remote-dispatcher-8] >>>>> [akka.serialization.Serialization(akka://ClusterSystem)] Using >>>>> serializer[akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer] >>>>> for message [akka.cluster.sharding.ShardCoordinator$Internal$Register] >>>>> [INFO] [12/19/2016 14:02:39.224] >>>>> [ClusterSystem-akka.actor.default-dispatcher-6] >>>>> [akka.tcp://[email protected]:2551/system/sharding/te >>>>> stCoordinator] ClusterSingletonManager state change [Start -> Younger] >>>>> [DEBUG] [12/19/2016 14:02:39.229] >>>>> [ClusterSystem-akka.actor.default-dispatcher-4] >>>>> [akka.tcp://[email protected]:2551/system/sharding/test] >>>>> Request shard [22] home >>>>> [WARN] [12/19/2016 14:02:49.211] >>>>> [ClusterSystem-akka.actor.default-dispatcher-4] >>>>> [akka.tcp://[email protected]:2551/system/sharding/test] >>>>> Trying to register to coordinator at [Some(ActorSelection[Anchor(ak >>>>> ka.tcp://[email protected]:2551/), >>>>> Path(/system/sharding/testCoordinator/singleton/coordinator)])], but >>>>> no acknowledgement. Total [1] buffered messages. >>>>> [WARN] [12/19/2016 14:02:51.219] >>>>> [ClusterSystem-akka.actor.default-dispatcher-17] >>>>> [akka.tcp://[email protected]:2551/system/sharding/test] >>>>> Trying to register to coordinator at [Some(ActorSelection[Anchor(ak >>>>> ka.tcp://[email protected]:2551/), >>>>> Path(/system/sharding/testCoordinator/singleton/coordinator)])], but >>>>> no acknowledgement. Total [1] buffered messages. >>>>> >>>>> So, the prestart and the “cluster.subscribe(self, >>>>> classOf[MemberEvent], classOf[UnreachableMember])” are not execute. >>>>> >>>>> Do you have another idea? >>>>> >>>>> Thank you so much for your help, >>>>> >>>>> >>>>> >>>>> Victor >>>>> >>>>> >>>>> >>>>> El domingo, 18 de diciembre de 2016, 13:53:29 (UTC-5), Patrik Nordwall >>>>> escribió: >>>>>> >>>>>> Perhaps you haven't joined the cluster? >>>>>> http://doc.akka.io/docs/akka/2.4/scala/cluster-usage.html#Jo >>>>>> ining_to_Seed_Nodes >>>>>> >>>>>> On Fri, Dec 16, 2016 at 11:04 PM, Víctor Martínez < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> >>>>>>> >>>>>>> In my test I have two nodes in cluster. The problem is the sharding >>>>>>> coordinator. When a younger node try to send a message just print. >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> [akka.tcp://ClusterSystem@localhost:2551/system/sharding/latamautos] >>>>>>> Trying to register to coordinator at [None], but no acknowledgement. >>>>>>> Total >>>>>>> [2] buffered messages. >>>>>>> >>>>>>> >>>>>>> >>>>>>> And never answer. But if a send a message to the oldest node the >>>>>>> coordinator sharding is create and the younger node work find. >>>>>>> >>>>>>> >>>>>>> >>>>>>> This is mi part from my conf file: >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Settings for the ClusterShardingExtension >>>>>>> >>>>>>> akka.cluster.sharding { >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> # The extension creates a top level actor with this name in top >>>>>>> level system scope, >>>>>>> >>>>>>> # e.g. '/system/sharding' >>>>>>> >>>>>>> guardian-name = sharding >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Specifies that entities runs on cluster nodes with a specific >>>>>>> role. >>>>>>> >>>>>>> # If the role is not specified (or empty) all nodes in the cluster >>>>>>> are used. >>>>>>> >>>>>>> role = "" >>>>>>> >>>>>>> >>>>>>> >>>>>>> # When this is set to 'on' the active entity actors will >>>>>>> automatically be restarted >>>>>>> >>>>>>> # upon Shard restart. i.e. if the Shard is started on a different >>>>>>> ShardRegion >>>>>>> >>>>>>> # due to rebalance or crash. >>>>>>> >>>>>>> remember-entities = on >>>>>>> >>>>>>> >>>>>>> >>>>>>> # If the coordinator can't store state changes it will be stopped >>>>>>> >>>>>>> # and started again after this duration, with an exponential >>>>>>> back-off >>>>>>> >>>>>>> # of up to 5 times this duration. >>>>>>> >>>>>>> coordinator-failure-backoff = 5 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # The ShardRegion retries registration and shard location requests >>>>>>> to the >>>>>>> >>>>>>> # ShardCoordinator with this interval if it does not reply. >>>>>>> >>>>>>> retry-interval = 2 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Maximum number of messages that are buffered by a ShardRegion >>>>>>> actor. >>>>>>> >>>>>>> buffer-size = 100000 >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Timeout of the shard rebalancing process. >>>>>>> >>>>>>> handoff-timeout = 60 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Time given to a region to acknowledge it's hosting a shard. >>>>>>> >>>>>>> shard-start-timeout = 10 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # If the shard is remembering entities and can't store state >>>>>>> changes >>>>>>> >>>>>>> # will be stopped and then started again after this duration. Any >>>>>>> messages >>>>>>> >>>>>>> # sent to an affected entity may be lost in this process. >>>>>>> >>>>>>> shard-failure-backoff = 10 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # If the shard is remembering entities and an entity stops itself >>>>>>> without >>>>>>> >>>>>>> # using passivate. The entity will be restarted after this >>>>>>> duration or when >>>>>>> >>>>>>> # the next message for it is received, which ever occurs first. >>>>>>> >>>>>>> entity-restart-backoff = 10 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Rebalance check is performed periodically with this interval. >>>>>>> >>>>>>> rebalance-interval = 10 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Absolute path to the journal plugin configuration entity that is >>>>>>> to be >>>>>>> >>>>>>> # used for the internal persistence of ClusterSharding. If not >>>>>>> defined >>>>>>> >>>>>>> # the default journal plugin is used. Note that this is not >>>>>>> related to >>>>>>> >>>>>>> # persistence used by the entity actors. >>>>>>> >>>>>>> journal-plugin-id = "cassandra-journal" >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Absolute path to the snapshot plugin configuration entity that >>>>>>> is to be >>>>>>> >>>>>>> # used for the internal persistence of ClusterSharding. If not >>>>>>> defined >>>>>>> >>>>>>> # the default snapshot plugin is used. Note that this is not >>>>>>> related to >>>>>>> >>>>>>> # persistence used by the entity actors. >>>>>>> >>>>>>> snapshot-plugin-id = "cassandra-snapshot-store" >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Parameter which determines how the coordinator will be store a >>>>>>> state >>>>>>> >>>>>>> # valid values either "persistence" or "ddata" >>>>>>> >>>>>>> # The "ddata" mode is experimental, since it depends on the >>>>>>> experimental >>>>>>> >>>>>>> # module akka-distributed-data-experimental. >>>>>>> >>>>>>> # state-store-mode = "persistence" >>>>>>> >>>>>>> state-store-mode = "persistence" >>>>>>> >>>>>>> >>>>>>> >>>>>>> # The shard saves persistent snapshots after this number of >>>>>>> persistent >>>>>>> >>>>>>> # events. Snapshots are used to reduce recovery times. >>>>>>> >>>>>>> snapshot-after = 1000 >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Setting for the default shard allocation strategy >>>>>>> >>>>>>> least-shard-allocation-strategy { >>>>>>> >>>>>>> # Threshold of how large the difference between most and least >>>>>>> number of >>>>>>> >>>>>>> # allocated shards must be to begin the rebalancing. >>>>>>> >>>>>>> rebalance-threshold = 3 >>>>>>> >>>>>>> >>>>>>> >>>>>>> # The number of ongoing rebalancing processes is limited to this >>>>>>> number. >>>>>>> >>>>>>> max-simultaneous-rebalance = 4 >>>>>>> >>>>>>> } >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Timeout of waiting the initial distributed state (an initial >>>>>>> state will be queried again if the timeout happened) >>>>>>> >>>>>>> # works only for state-store-mode = "ddata" >>>>>>> >>>>>>> waiting-for-state-timeout = 5 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Timeout of waiting for update the distributed state (update will >>>>>>> be retried if the timeout happened) >>>>>>> >>>>>>> # works only for state-store-mode = "ddata" >>>>>>> >>>>>>> updating-state-timeout = 5 s >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Settings for the coordinator singleton. Same layout as >>>>>>> akka.cluster.singleton. >>>>>>> >>>>>>> coordinator-singleton = ${akka.cluster.singleton} >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> # The shard uses this strategy to determines how to recover the >>>>>>> underlying entity actors. The strategy is only used >>>>>>> >>>>>>> # by the persistent shard when rebalancing or restarting. The >>>>>>> value can either be "all" or "constant". The "all" >>>>>>> >>>>>>> # strategy start all the underlying entity actors at the same >>>>>>> time. The constant strategy will start the underlying >>>>>>> >>>>>>> # entity actors at a fix rate. The default strategy "all". >>>>>>> >>>>>>> entity-recovery-strategy = "all" >>>>>>> >>>>>>> >>>>>>> >>>>>>> # Default settings for the constant rate entity recovery strategy >>>>>>> >>>>>>> entity-recovery-constant-rate-strategy { >>>>>>> >>>>>>> # Sets the frequency at which a batch of entity actors is >>>>>>> started. >>>>>>> >>>>>>> frequency = 100 ms >>>>>>> >>>>>>> # Sets the number of entity actors to be restart at a particular >>>>>>> interval >>>>>>> >>>>>>> number-of-entities = 5 >>>>>>> >>>>>>> } >>>>>>> >>>>>>> >>>>>>> >>>>>>> } >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> I don’t understood what is wrong >>>>>>> >>>>>>> >>>>>>> >>>>>>> Thanks >>>>>>> >>>>>>> >>>>>>> >>>>>>> Victor >>>>>>> >>>>>>> -- >>>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>>>>>> urrent/additional/faq.html >>>>>>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>>>>>> p/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 https://groups.google.com/group/akka-user. >>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> >>>>>> Patrik Nordwall >>>>>> Akka Tech Lead >>>>>> Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM >>>>>> Twitter: @patriknw >>>>>> >>>>>> -- >>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>>>> urrent/additional/faq.html >>>>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>>>> p/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 https://groups.google.com/group/akka-user. >>>>> For more options, visit https://groups.google.com/d/optout. >>>>> >>>> >>>> >>>> >>>> -- >>>> >>>> Patrik Nordwall >>>> Akka Tech Lead >>>> Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM >>>> Twitter: @patriknw >>>> >>>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>> urrent/additional/faq.html >>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>> p/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 https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> -- > >>>>>>>>>> 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
