You need to ensure your nimbus port is open for other hosts to connect. The default value is 6627.
Thanks Parth From: Armando Martinez Briones <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Date: Thursday, February 26, 2015 at 11:24 AM To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Subject: Cluster Storm 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 -- [Tralix] José Armando Martínez Briones Arquitecto de software Tralix México Tel: +52 442 161 1002 ext. 2920 www.tralix.com.mx<http://www.tralix.com.mx/> [http://tralix.com.mx/img/firma/firma_2014/t.jpg]<https://twitter.com/#!/tralix> [http://tralix.com.mx/img/firma/firma_2014/f.jpg] <http://www.facebook.com/pages/Tralix/47723192646> [http://tralix.com.mx/img/firma/firma_2014/line4.jpg] TRALIX MÉXICO S. DE R.L. DE C.V como responsable del tratamiento de sus datos personales, hace de su conocimiento que la información obtenida por este medio es tratada de forma estrictamente confidencial por lo que recabaremos y trataremos de sus datos según los lineamientos de nuestro Aviso de Privacidad<http://tralix.com.mx/politicasdeprivacidad/avisodeprivacidad.html>. Para conocer la versión completa podrá hacerlo a través de la página Aviso de privacidad. Al leer el presente Aviso de Privacidad y no manifestar su oposición al tratamiento de sus Datos Personales, se entiende que usted conoció la versión completa y acepta los términos del mismo, siempre de conformidad a la Ley Federal de Protección de Datos Personales en Posesión de los Particulares.
