storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Armando Martinez Briones <arma...@tralix.com>
Subject Cluster Storm
Date Thu, 26 Feb 2015 19:24:24 GMT
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




-- 
[image: Tralix][image: 1]José Armando Martínez Briones
*Arquitecto de software*
Tralix México
Tel: +52 442 161 1002  ext. 2920
www.tralix.com.mx
<https://twitter.com/#!/tralix>
<http://www.facebook.com/pages/Tralix/47723192646>*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