Is your nimbus running on the default port? Can you also check nimbus logs?
Thanks Parth From: Susana González <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Date: Friday, February 27, 2015 at 12:22 AM To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Subject: Re: Cluster Storm Hi, You also need to have connection to the Zookeeper server port (by default, 2181/tcp). Regards, Susana On Thu, Feb 26, 2015 at 8:56 PM, Armando Martinez Briones <[email protected]<mailto:[email protected]>> wrote: I'm sure that the port is open because I can open a telnet connection telnet IPServer1 6627 Trying 10.0.8.79... Connected to 10.0.8.79. Escape character is '^]'. Thanks 2015-02-26 13:28 GMT-06:00 Parth Brahmbhatt <[email protected]<mailto:[email protected]>>: 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<tel:%2B52%20442%20161%201002%C2%A0%20ext.%202920> 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. -- [Tralix] José Armando Martínez Briones Arquitecto de software Tralix México Tel: +52 442 161 1002 ext. 2920<tel:%2B52%20442%20161%201002%C2%A0%20ext.%202920> 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.
