Hi folks,
I've been taking a look at the clustering sample project provided with the
Typesafe Activator
<http://www.lightbend.com/activator/template/akka-sample-cluster-scala>,
and I'm having some trouble with joining a remotely running cluster.
I've got the project set up on two machines, the first machine has two
instances of the "SimpleClusterApp" running. The consoles for these two
processes is showing what I'd expect, membership messages showing that both
nodes are on the cluster.
I wanted to see if I could connect a third instance of this from the second
machine, but I can't get the config right. In the application.conf file,
I've got the following:
akka {
actor {
provider = "akka.cluster.ClusterActorRefProvider"
}
remote {
log-remote-lifecycle-events = off
netty.tcp {
hostname = "Scott-PC"
port = 0
}
}
cluster {
seed-nodes = [
"akka.tcp://ClusterSystem@Scott-PC:2551",
"akka.tcp://ClusterSystem@Scott-PC:2552"]
auto-down-unreachable-after = 10s
}
}
# Disable legacy metrics in akka-cluster.
akka.cluster.metrics.enabled=off
# Enable metrics extension in akka-cluster-metrics.
akka.extensions=["akka.cluster.metrics.ClusterMetricsExtension"]
# Sigar native library extract location during tests.
# Note: use per-jvm-instance folder when running multiple jvm on one host.
akka.cluster.metrics.native-library-extract-folder=${user.dir}/target/native
Where Scott-PC is the hostname of the machine running the first two
processes. The two parts that I've changed here are the
"akka.remote.netty.tcp.hostname" and the "cluster.seed-nodes" properties
(to use the other machine's hostname).
When I try to run a new process on the second machine I get the following
output:
PS C:\Users\smackie\akka-sample-cluster-java> .\activator "runMain
sample.cluster.simple.SimpleClusterApp 2551"
[info] Loading project definition from
C:\Users\smackie\akka-sample-cluster-java\project
[info] Set current project to akka-sample-cluster-java (in build
file:/C:/Users/smackie/akka-sample-cluster-java/)
[info] Running sample.cluster.simple.SimpleClusterApp 2551
[info] [INFO] [03/17/2016 00:10:18.495] [main] [akka.remote.Remoting]
Starting remoting
[info] [ERROR] [03/17/2016 00:10:18.799]
[ClusterSystem-akka.remote.default-remote-dispatcher-5]
[NettyTransport(akka://
ClusterSystem)] failed to bind to Scott-PC/192.168.0.2:2551, shutting down
Netty transport
[error] Exception in thread "main"
org.jboss.netty.channel.ChannelException: Failed to bind to:
Scott-PC/192.168.0.2:255
1
[error] at
org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272)
[error] at
akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:410)
[error] at
akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:406)
[error] at scala.util.Success$$anonfun$map$1.apply(Try.scala:237)
[error] at scala.util.Try$.apply(Try.scala:192)
[info] [INFO] [03/17/2016 00:10:18.808]
[ClusterSystem-akka.remote.default-remote-dispatcher-6]
[akka://ClusterSystem/sy
stem/remoting-terminator] Shutting down remote daemon.
[error] at scala.util.Success.map(Try.scala:237)
[error] at
scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:235)
[info] [INFO] [03/17/2016 00:10:18.810]
[ClusterSystem-akka.remote.default-remote-dispatcher-6]
[akka://ClusterSystem/sy
stem/remoting-terminator] Remote daemon shut down; proceeding with flushing
remote transports.
[error] at
scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:235)
[error] at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
[error] at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
[error] at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
[info] [INFO] [03/17/2016 00:10:18.812]
[ClusterSystem-akka.remote.default-remote-dispatcher-6]
[akka://ClusterSystem/sy
stem/remoting-terminator] Remoting shut down.
[error] at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
[info] [ERROR] [03/17/2016 00:10:18.813]
[ClusterSystem-akka.remote.default-remote-dispatcher-5]
[akka.remote.Remoting]
Remoting system has been terminated abrubtly. Attempting to shut down
transports
[error] at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
[error] at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
[error] at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
[error] at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
[error] at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:399)
[error] at
scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[error] at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[error] at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[error] at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[error] Caused by: java.net.BindException: Cannot assign requested address:
bind
[error] at sun.nio.ch.Net.bind0(Native Method)
[error] at sun.nio.ch.Net.bind(Net.java:433)
[error] at sun.nio.ch.Net.bind(Net.java:425)
[error] at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
[error] at
sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
[error] at
org.jboss.netty.channel.socket.nio.NioServerBoss$RegisterTask.run(NioServerBoss.java:193)
[error] at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:391)
[error] at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:315)
[error] at
org.jboss.netty.channel.socket.nio.NioServerBoss.run(NioServerBoss.java:42)
[error] at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
[error] at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
[error] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[error] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[error] at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException: Nonzero exit code returned from runner: 1
at scala.sys.package$.error(package.scala:27)
[trace] Stack trace suppressed: run last compile:runMain for the full
output.
[error] (compile:runMain) Nonzero exit code returned from runner: 1
[error] Total time: 1 s, completed Mar 17, 2016 12:10:18 AM
Any idea what I'm doing wrong?
Thanks,
Scott
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
