Hi.
I have a cluster of storm with 3 servers:
Server 1: zookeeper, nimbus and one supervisor
Server 2: one supervisor
Server 3: one supervisor
When I start the supervisors on the server 2 and server 3, the Server 1 identify OK the supervisors and I can see on the UI 3 supervisors, but when I deploy a topology and rebalance it, on the logs of supervisors of Server 2 and Server 3 show the next
exception:
I need open a special port? or specials permissions??
2015-02-26 19:05:02 b.s.d.supervisor [INFO] Downloading code for storm id COMPLETADO_TOPOLOGY-8-1424972394 from /opt/var/storm/data/nimbus/stormdist/COMPLETADO_TOPOLOGY-8-1424972394
2015-02-26 19:05:02 b.s.event [ERROR] Error when processing event
java.lang.RuntimeException: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused
at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:38) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.utils.Utils.downloadFromMaster(Utils.java:260) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.daemon.supervisor$fn__6412.invoke(supervisor.clj:434) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at clojure.lang.MultiFn.invoke(MultiFn.java:236) ~[clojure-1.5.1.jar:na]
at backtype.storm.daemon.supervisor$mk_synchronize_supervisor$this__6330.invoke(supervisor.clj:325) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.event$event_manager$fn__2378.invoke(event.clj:39) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_67]
Caused by: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused
at org.apache.thrift7.transport.TSocket.open(TSocket.java:183) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at org.apache.thrift7.transport.TFramedTransport.open(TFramedTransport.java:81) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:83) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.security.auth.ThriftClient.<init>(ThriftClient.java:63) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:47) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:43) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:36) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
... 7 common frames omitted
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.7.0_67]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339) ~[na:1.7.0_67]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200) ~[na:1.7.0_67]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182) ~[na:1.7.0_67]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.7.0_67]
at java.net.Socket.connect(Socket.java:579) ~[na:1.7.0_67]
at org.apache.thrift7.transport.TSocket.open(TSocket.java:178) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
... 13 common frames omitted