Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Multiple Supervisors #8

Open
sametserpil opened this issue Aug 18, 2015 · 2 comments
Open

Multiple Supervisors #8

sametserpil opened this issue Aug 18, 2015 · 2 comments

Comments

@sametserpil
Copy link

How can I run multiple supervisors? I mean, each supervisor is a different docker instance.

@fhussonnois
Copy link
Owner

If you would like to run multiple supervisors on the same host, you have to mount your own storm.yaml to configure differents ports for workers --volume /local/path/conf/:/usr/share/apache-storm/conf

If want to deploy supervisors on multiple hosts : You can use the ambassador pattern :
https://gist.github.com/azhawkes/34283f6209f1697d7578#file-docker-deploy-storm-cluster-sh

@sametserpil
Copy link
Author

I get the following error:

2015-08-18 12:52:13 b.s.m.n.StormClientErrorHandler [INFO] Connection failed Netty-Client-117349db4f9c:6713
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:127) ~[na:1.7.0_79]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:645) ~[na:1.7.0_79]
at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.Channels.connect(Channels.java:634) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) [storm-core-0.9.4.jar:0.9.4]
at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) [storm-core-0.9.4.jar:0.9.4]
at backtype.storm.messaging.netty.Client$Connector.call(Client.java:612) [storm-core-0.9.4.jar:0.9.4]
at backtype.storm.messaging.netty.Client$Connector.call(Client.java:595) [storm-core-0.9.4.jar:0.9.4]
at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_79]
at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) [na:1.7.0_79]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) [na:1.7.0_79]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_79]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_79]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants