You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Armando Martinez Briones <ar...@tralix.com> on 2015/02/26 20:24:24 UTC
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
--
[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.
Re: Cluster Storm
Posted by Parth Brahmbhatt <pb...@hortonworks.com>.
Is your nimbus running on the default port? Can you also check nimbus logs?
Thanks
Parth
From: Susana González <su...@gmail.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Friday, February 27, 2015 at 12:22 AM
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
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 <ar...@tralix.com>> 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 <pb...@hortonworks.com>>:
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 <ar...@tralix.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Thursday, February 26, 2015 at 11:24 AM
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@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<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.
Re: Cluster Storm
Posted by Susana González <su...@gmail.com>.
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 <
armando@tralix.com> 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 <pb...@hortonworks.com>:
>
> 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 <ar...@tralix.com>
>> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
>> Date: Thursday, February 26, 2015 at 11:24 AM
>> To: "user@storm.apache.org" <us...@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
>>
>>
>>
>>
>> --
>> [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.
>>
>
>
>
> --
> [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.
>
Re: Cluster Storm
Posted by Armando Martinez Briones <ar...@tralix.com>.
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 <pb...@hortonworks.com>:
> 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 <ar...@tralix.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Thursday, February 26, 2015 at 11:24 AM
> To: "user@storm.apache.org" <us...@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
>
>
>
>
> --
> [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.
>
--
[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.
Re: Cluster Storm
Posted by Parth Brahmbhatt <pb...@hortonworks.com>.
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 <ar...@tralix.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Thursday, February 26, 2015 at 11:24 AM
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@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.
Fwd: Cluster Storm
Posted by Armando Martinez Briones <ar...@tralix.com>.
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.