storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Parth Brahmbhatt <pbrahmbh...@hortonworks.com>
Subject Re: Cluster Storm
Date Thu, 26 Feb 2015 19:28:37 GMT
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 <armando@tralix.com<mailto:armando@tralix.com>>
Reply-To: "user@storm.apache.org<mailto:user@storm.apache.org>" <user@storm.apache.org<mailto:user@storm.apache.org>>
Date: Thursday, February 26, 2015 at 11:24 AM
To: "user@storm.apache.org<mailto:user@storm.apache.org>" <user@storm.apache.org<mailto:user@storm.apache.org>>
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.

Mime
View raw message