storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Susana González <susan...@gmail.com>
Subject Re: Cluster Storm
Date Fri, 27 Feb 2015 08:22:34 GMT
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 <pbrahmbhatt@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 <armando@tralix.com>
>> Reply-To: "user@storm.apache.org" <user@storm.apache.org>
>> Date: Thursday, February 26, 2015 at 11:24 AM
>> To: "user@storm.apache.org" <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
>>
>>
>>
>>
>>  --
>>    [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.
>

Mime
View raw message