Hi Roland,
Thank you for your advice. I think I tried this and it didn't work for some
reason, but I don't remember it now. Anyway, I solved this issue by
dynamically discovering IP address at node start up and setting up
configuration from Java code rather then from application.conf.
I'm able to connect new worker nodes without having to know their IP and
ports. However, shortly after the second worker is connected, all nodes are
disconnected and error message is:
[WARN] [02/13/2014 23:50:25.736]
[ClusterSystem-akka.remote.default-remote-dispatcher-5]
[akka.tcp://ClusterSystem@100.71.52.66:41754/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FClusterSystem%40100.71.54.43%3A39932-1]
Association with remote system
[akka.tcp://ClusterSystem@100.71.54.43:39932] has failed, address is now
gated for [5000] ms. Reason is: [Association failed with
[akka.tcp://ClusterSystem@100.71.54.43:39932]].
[INFO] [02/13/2014 23:50:25.748]
> [ClusterSystem-akka.actor.default-dispatcher-4]
> [akka://ClusterSystem/deadLetters] Message
> [com.inextweb.crawler.akka.messages.GeneralJobMessage] from
> Actor[akka://ClusterSystem/remote/akka.tcp/ClusterSystem@100.71.110.33:2551/user/clusterController/crawlerManager/c2#-993579407]
>
> to Actor[akka://ClusterSystem/deadLetters] was not delivered. [1] dead
> letters encountered. This logging can be turned off or adjusted with
> configuration settings 'akka.log-dead-letters' and
> 'akka.log-dead-letters-during-shutdown'.
>
> [WARN] [02/13/2014 23:50:29.399]
> [ClusterSystem-akka.cluster.cluster-dispatcher-16]
> [akka.tcp://ClusterSystem@100.71.52.66:41754/system/cluster/core/daemon]
> Cluster Node [akka.tcp://ClusterSystem@100.71.52.66:41754] - Marking
> node(s) as UNREACHABLE [Member(address =
> akka.tcp://ClusterSystem@100.71.54.43:39932, status = Up)]
> [WARN] [02/13/2014 23:50:46.271]
> [ClusterSystem-akka.remote.default-remote-dispatcher-6]
> [akka.tcp://ClusterSystem@100.71.52.66:41754/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FClusterSystem%40100.71.54.43%3A39932-1]
>
> Association with remote system
> [akka.tcp://ClusterSystem@100.71.54.43:39932] has failed, address is now
> gated for [5000] ms. Reason is: [Association failed with
> [akka.tcp://ClusterSystem@100.71.54.43:39932]].
>
Do you have any idea what could cause this failure? It's not happening
until I try to connect second worker.
Thanks
On Thursday, 13 February 2014 03:45:15 UTC-8, rkuhn wrote:
>
> Hi Zoran,
>
> on the worker nodes you can configure
>
> hostname=""
> port=0
>
> since they just need to find the master.
>
> Regards,
>
> Roland
>
> 12 feb 2014 kl. 03:17 skrev Zoran Jeremic <zoran....@gmail.com<javascript:>
> >:
>
> Hi,
>
> I've implemented Akka cluster where I have one master node that initialize
> cluster in the following way:
>
>
> AdaptiveLoadBalancingPool pool = new AdaptiveLoadBalancingPool(
>> MixMetricsSelector.getInstance(), 0);
>> ClusterRouterPoolSettings settings = new
>> ClusterRouterPoolSettings(
>> totalInstances, maxInstancesPerNode, allowLocalRoutees,
>> useRole);
>> crawlerManager = getContext().actorOf(
>> new ClusterRouterPool(pool, settings).props(Props.create(
>> CrawlerManagerActor.class, getSelf())),
>> "crawlerManager");
>
>
> It's configure like as:
>
> akka {
>> actor {
>> provider = "akka.cluster.ClusterActorRefProvider"
>> }
>> remote {
>> log-remote-lifecycle-events = off
>> netty.tcp {
>> hostname = "100.71.88.118"
>> port=2551
>> }
>> }
>> cluster {
>> seed-nodes = [
>> "akka.tcp://ClusterSystem@100.71.88.118:2551"
>> ]
>
>
> And I have a worker node which is configured as:
>
>
> akka {
>> actor {
>> provider = "akka.cluster.ClusterActorRefProvider"
>> }
>> remote {
>> log-remote-lifecycle-events = off
>> netty.tcp {
>> hostname = "100.71.96.54"
>> port=2552
>> }
>> }
>> cluster {
>> seed-nodes = [
>> "akka.tcp://ClusterSystem@100.71.88.118:2551"
>> ]
>
>
> Each node is on different instance in Microsoft Azure cloud,but what I
> want is to create an image from worker and based on that image to create
> new instances of workers when system load is increased, so hostname and
> port should be created dynamically. However, from Akka documentation and
> previous discussion I couldn't find any description that will help me how
> to make this work. Could you give me some reference or description what
> have to be done and how to configure my nodes once it's loaded.
>
> Thanks,
> Zoran
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ: http://akka.io/faq/
> >>>>>>>>>> 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 akka-user+...@googlegroups.com <javascript:>.
> To post to this group, send email to akka...@googlegroups.com<javascript:>
> .
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/groups/opt_out.
>
>
>
>
> *Dr. Roland Kuhn*
> *Akka Tech Lead*
> Typesafe <http://typesafe.com/> – Reactive apps on the JVM.
> twitter: @rolandkuhn
> <http://twitter.com/#!/rolandkuhn>
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ: http://akka.io/faq/
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/groups/opt_out.
