You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Al Hennessey <al...@gmail.com> on 2016/11/18 21:27:46 UTC
Cant connect to remote cluster
Hi, i am having an issue connecting to my remote clustered storm server, when i try running “storm list” i get this error
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
at org.apache.storm.command.list$_main.invoke(list.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:152)
at clojure.lang.AFn.applyTo(AFn.java:144)
at org.apache.storm.command.list.main(Unknown Source)
Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
... 8 more
Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
Here is my nimbus storm.yaml
nimbus.seeds:
- "130.211.53.188"
nimbus.thrift.port: 6627
storm.local.dir: /var/storm-dir
storm.zookeeper.servers:
- "104.199.7.70"
ui.host: 0.0.0.0
ui.port: 8080
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
My client storm uses the same nimbus host line:
nimbus.seeds:
- “130.211.53.188”
Not sure why i can’t connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
Thanks for the help
Re: Cant connect to remote cluster
Posted by Mostafa Gomaa <mg...@trendak.com>.
Looks like it's a firewall settings issue. Try sudo ufw allow 6627 on your
nimbus machine
On Nov 19, 2016 12:17 AM, "Al Hennessey" <al...@gmail.com> wrote:
> Yes i used the domain name for the nimbus seed
>
> On 18 Nov 2016, at 22:15, sam mohel <sa...@gmail.com> wrote:
>
> Did you try to use domain name in storm.yaml instead of IP address for
> nimbus ?
>
> On Saturday, November 19, 2016, Al Hennessey <al...@gmail.com>
> wrote:
>
>> Hi, i thanks for the reply, i added the ip to my hosts file with a domain
>> name, but it still did not work and threw the same error
>> Just to let you know that i am on a mac
>>
>> Thanks for the help
>>
>> On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
>>
>> m new to storm but let's try that and I hope it will work
>> Check the file which has definitions of IP
>> It exists in this path
>> /ets/hosts it should contains like 127.0.x.x mydomain
>> 1- Check that 130.211.53.188 has domain name or it already exists or
>> 2-If you found it try to use the domain name instead of IP address
>> On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>
>> wrote:
>>
>>> Hi, i am having an issue connecting to my remote clustered storm server,
>>> when i try running “storm list” i get this error
>>>
>>> Exception in thread "main" java.lang.RuntimeException:
>>> org.apache.storm.thrift.transport.TTransportException:
>>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBa
>>> ckoffConnect.java:64)
>>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>>> Retry(TBackoffConnect.java:56)
>>> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
>>> Client.java:99)
>>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
>>> ent.java:69)
>>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
>>> mbusClient.java:78)
>>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>>> at clojure.lang.AFn.applyTo(AFn.java:144)
>>> at org.apache.storm.command.list.main(Unknown Source)
>>> Caused by: org.apache.storm.thrift.transport.TTransportException:
>>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>>> at org.apache.storm.thrift.transport.TFramedTransport.open(TFra
>>> medTransport.java:81)
>>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
>>> (SimpleTransportPlugin.java:103)
>>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>>> Retry(TBackoffConnect.java:53)
>>> ... 8 more
>>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>>> Impl.java:184)
>>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>>> at java.net.Socket.connect(Socket.java:589)
>>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>>
>>>
>>> Here is my nimbus storm.yaml
>>>
>>> nimbus.seeds:
>>> - "130.211.53.188"
>>> nimbus.thrift.port: 6627
>>> storm.local.dir: /var/storm-dir
>>> storm.zookeeper.servers:
>>> - "104.199.7.70"
>>> ui.host: 0.0.0.0
>>> ui.port: 8080
>>> supervisor.slots.ports:
>>> - 6700
>>> - 6701
>>> - 6702
>>> - 6703
>>>
>>> My client storm uses the same nimbus host line:
>>>
>>> nimbus.seeds:
>>> - “130.211.53.188”
>>>
>>> Not sure why i can’t connect, i am running on google cloud platform and
>>> all my ports are open so it should be able to talk to each other.
>>>
>>> Thanks for the help
>>>
>>>
>>>
>>
>
Re: Cant connect to remote cluster
Posted by Al Hennessey <al...@gmail.com>.
Yes i used the domain name for the nimbus seed
> On 18 Nov 2016, at 22:15, sam mohel <sa...@gmail.com> wrote:
>
> Did you try to use domain name in storm.yaml instead of IP address for nimbus ?
>
> On Saturday, November 19, 2016, Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>> wrote:
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>> On 18 Nov 2016, at 22:01, sam mohel <sammohel5@gmail.com <javascript:_e(%7B%7D,'cvml','sammohel5@gmail.com');>> wrote:
>>
>> m new to storm but let's try that and I hope it will work
>> Check the file which has definitions of IP
>> It exists in this path
>> /ets/hosts it should contains like 127.0.x.x mydomain
>> 1- Check that 130.211.53.188 has domain name or it already exists or
>> 2-If you found it try to use the domain name instead of IP address
>> On Friday, November 18, 2016, Al Hennessey <alhennessey92@gmail.com <javascript:_e(%7B%7D,'cvml','alhennessey92@gmail.com');>> wrote:
>> Hi, i am having an issue connecting to my remote clustered storm server, when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net <http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>
Re: Cant connect to remote cluster
Posted by sam mohel <sa...@gmail.com>.
Did you try to use domain name in storm.yaml instead of IP address for
nimbus ?
On Saturday, November 19, 2016, Al Hennessey <al...@gmail.com>
wrote:
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain
> name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>
> On 18 Nov 2016, at 22:01, sam mohel <sammohel5@gmail.com
> <javascript:_e(%7B%7D,'cvml','sammohel5@gmail.com');>> wrote:
>
> m new to storm but let's try that and I hope it will work
> Check the file which has definitions of IP
> It exists in this path
> /ets/hosts it should contains like 127.0.x.x mydomain
> 1- Check that 130.211.53.188 has domain name or it already exists or
> 2-If you found it try to use the domain name instead of IP address
> On Friday, November 18, 2016, Al Hennessey <alhennessey92@gmail.com
> <javascript:_e(%7B%7D,'cvml','alhennessey92@gmail.com');>> wrote:
>
>> Hi, i am having an issue connecting to my remote clustered storm server,
>> when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException:
>> org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(
>> TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
>> Client.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
>> ent.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
>> mbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(
>> TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
>> (SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>> Impl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and
>> all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>>
>
Re: Cant connect to remote cluster
Posted by Al Hennessey <al...@gmail.com>.
I tried to connect via telnet and this is what i got
MacBook-Pro:~ Al$ telnet 130.211.53.188 6627
Trying 130.211.53.188...
telnet: connect to address 130.211.53.188: Connection refused
telnet: Unable to connect to remote host
> On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com> wrote:
>
> Did you try running the command, from the same machine?
>
> From: Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>>
> Reply-To: "user@storm.apache.org <ma...@storm.apache.org>" <user@storm.apache.org <ma...@storm.apache.org>>
> Date: Saturday, 19 November 2016 at 0:10
> To: "user@storm.apache.org <ma...@storm.apache.org>" <user@storm.apache.org <ma...@storm.apache.org>>
> Subject: Re: Cant connect to remote cluster
>
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>> On 18 Nov 2016, at 22:01, sam mohel <sammohel5@gmail.com <ma...@gmail.com>> wrote:
>>
>> m new to storm but let's try that and I hope it will work
>> Check the file which has definitions of IP
>> It exists in this path
>> /ets/hosts it should contains like 127.0.x.x
>> mydomain
>> 1- Check that 130.211.53.188 has domain name or it already exists or
>> 2-If you found it try to use the domain name instead of IP address
>> On Friday, November 18, 2016, Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>> wrote:
>> Hi, i am having an issue connecting to my remote clustered storm server, when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net <http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>
Re: Cant connect to remote cluster
Posted by Mostafa Gomaa <mg...@trendak.com>.
It could be a firewall issue, so check your firewall settings. Otherwise
it's probably a network settings issue. I had this problem before and i
fixed it by setting the hostname in /etc/hosts on the local and remote
machines.
On Nov 19, 2016 12:14 AM, "Al Hennessey" <al...@gmail.com> wrote:
> Yh i ran the same command from the nimbus machine and it worked fine
>
> On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com> wrote:
>
> Did you try running the command, from the same machine?
>
> From: Al Hennessey <al...@gmail.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Saturday, 19 November 2016 at 0:10
> To: "user@storm.apache.org" <us...@storm.apache.org>
> Subject: Re: Cant connect to remote cluster
>
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain
> name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>
> On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
>
> m new to storm but let's try that and I hope it will work
> Check the file which has definitions of IP
> It exists in this path
> /ets/hosts it should contains like 127.0.x.x mydomain
> 1- Check that 130.211.53.188 has domain name or it already exists or
> 2-If you found it try to use the domain name instead of IP address
> On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>
> wrote:
>
>> Hi, i am having an issue connecting to my remote clustered storm server,
>> when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException:
>> org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(
>> TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
>> Client.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
>> ent.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
>> mbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(
>> TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
>> (SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>> Impl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and
>> all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>>
>
>
Re: Cant connect to remote cluster
Posted by Ambud Sharma <as...@gmail.com>.
Please use IRC for this. Mailing list is not for Instant Messaging.
On Nov 18, 2016 2:21 PM, "Mostafa Gomaa" <mg...@trendak.com> wrote:
Also is nimbus by any chance hosted on AWS or Azure?
On Nov 19, 2016 12:18 AM, "Ohad Edelstein" <oh...@mintigo.com> wrote:
> Try add the zookeeper part to the client storm.yaml
>
> I think that the request is searching for the zookeeper to pass the
> message and fails
>
> From: Al Hennessey <al...@gmail.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Saturday, 19 November 2016 at 0:13
> To: "user@storm.apache.org" <us...@storm.apache.org>
> Subject: Re: Cant connect to remote cluster
>
> Yh i ran the same command from the nimbus machine and it worked fine
>
> On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com> wrote:
>
> Did you try running the command, from the same machine?
>
> From: Al Hennessey <al...@gmail.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Saturday, 19 November 2016 at 0:10
> To: "user@storm.apache.org" <us...@storm.apache.org>
> Subject: Re: Cant connect to remote cluster
>
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain
> name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>
> On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
>
> m new to storm but let's try that and I hope it will work
> Check the file which has definitions of IP
> It exists in this path
> /ets/hosts it should contains like 127.0.x.x mydomain
> 1- Check that 130.211.53.188 has domain name or it already exists or
> 2-If you found it try to use the domain name instead of IP address
> On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>
> wrote:
>
>> Hi, i am having an issue connecting to my remote clustered storm server,
>> when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException:
>> org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBa
>> ckoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
>> Client.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
>> ent.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
>> mbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(TFra
>> medTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
>> (SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>> Impl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and
>> all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>>
>
>
Re: Cant connect to remote cluster
Posted by Mostafa Gomaa <mg...@trendak.com>.
Also is nimbus by any chance hosted on AWS or Azure?
On Nov 19, 2016 12:18 AM, "Ohad Edelstein" <oh...@mintigo.com> wrote:
> Try add the zookeeper part to the client storm.yaml
>
> I think that the request is searching for the zookeeper to pass the
> message and fails
>
> From: Al Hennessey <al...@gmail.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Saturday, 19 November 2016 at 0:13
> To: "user@storm.apache.org" <us...@storm.apache.org>
> Subject: Re: Cant connect to remote cluster
>
> Yh i ran the same command from the nimbus machine and it worked fine
>
> On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com> wrote:
>
> Did you try running the command, from the same machine?
>
> From: Al Hennessey <al...@gmail.com>
> Reply-To: "user@storm.apache.org" <us...@storm.apache.org>
> Date: Saturday, 19 November 2016 at 0:10
> To: "user@storm.apache.org" <us...@storm.apache.org>
> Subject: Re: Cant connect to remote cluster
>
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain
> name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>
> On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
>
> m new to storm but let's try that and I hope it will work
> Check the file which has definitions of IP
> It exists in this path
> /ets/hosts it should contains like 127.0.x.x mydomain
> 1- Check that 130.211.53.188 has domain name or it already exists or
> 2-If you found it try to use the domain name instead of IP address
> On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>
> wrote:
>
>> Hi, i am having an issue connecting to my remote clustered storm server,
>> when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException:
>> org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(
>> TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
>> Client.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
>> ent.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
>> mbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException:
>> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(
>> TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
>> (SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
>> Retry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>> Impl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and
>> all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>>
>
>
Re: Cant connect to remote cluster
Posted by Ohad Edelstein <oh...@mintigo.com>.
Try add the zookeeper part to the client storm.yaml
I think that the request is searching for the zookeeper to pass the message and fails
From: Al Hennessey <al...@gmail.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Saturday, 19 November 2016 at 0:13
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Subject: Re: Cant connect to remote cluster
Yh i ran the same command from the nimbus machine and it worked fine
On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com>> wrote:
Did you try running the command, from the same machine?
From: Al Hennessey <al...@gmail.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Saturday, 19 November 2016 at 0:10
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Subject: Re: Cant connect to remote cluster
Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
Just to let you know that i am on a mac
Thanks for the help
On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com>> wrote:
m new to storm but let's try that and I hope it will work
Check the file which has definitions of IP
It exists in this path
/ets/hosts it should contains like 127.0.x.x mydomain
1- Check that 130.211.53.188 has domain name or it already exists or
2-If you found it try to use the domain name instead of IP address
On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>> wrote:
Hi, i am having an issue connecting to my remote clustered storm server, when i try running "storm list" i get this error
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
at org.apache.storm.command.list$_main.invoke(list.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:152)
at clojure.lang.AFn.applyTo(AFn.java:144)
at org.apache.storm.command.list.main(Unknown Source)
Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
... 8 more
Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at java.net<http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
Here is my nimbus storm.yaml
nimbus.seeds:
- "130.211.53.188"
nimbus.thrift.port: 6627
storm.local.dir: /var/storm-dir
storm.zookeeper.servers:
- "104.199.7.70"
ui.host: 0.0.0.0
ui.port: 8080
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
My client storm uses the same nimbus host line:
nimbus.seeds:
- "130.211.53.188"
Not sure why i can't connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
Thanks for the help
Re: Cant connect to remote cluster
Posted by Al Hennessey <al...@gmail.com>.
Yh i ran the same command from the nimbus machine and it worked fine
> On 18 Nov 2016, at 22:12, Ohad Edelstein <oh...@mintigo.com> wrote:
>
> Did you try running the command, from the same machine?
>
> From: Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>>
> Reply-To: "user@storm.apache.org <ma...@storm.apache.org>" <user@storm.apache.org <ma...@storm.apache.org>>
> Date: Saturday, 19 November 2016 at 0:10
> To: "user@storm.apache.org <ma...@storm.apache.org>" <user@storm.apache.org <ma...@storm.apache.org>>
> Subject: Re: Cant connect to remote cluster
>
> Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
> Just to let you know that i am on a mac
>
> Thanks for the help
>> On 18 Nov 2016, at 22:01, sam mohel <sammohel5@gmail.com <ma...@gmail.com>> wrote:
>>
>> m new to storm but let's try that and I hope it will work
>> Check the file which has definitions of IP
>> It exists in this path
>> /ets/hosts it should contains like 127.0.x.x
>> mydomain
>> 1- Check that 130.211.53.188 has domain name or it already exists or
>> 2-If you found it try to use the domain name instead of IP address
>> On Friday, November 18, 2016, Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>> wrote:
>> Hi, i am having an issue connecting to my remote clustered storm server, when i try running “storm list” i get this error
>>
>> Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
>> at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
>> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
>> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
>> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
>> at org.apache.storm.command.list$_main.invoke(list.clj:22)
>> at clojure.lang.AFn.applyToHelper(AFn.java:152)
>> at clojure.lang.AFn.applyTo(AFn.java:144)
>> at org.apache.storm.command.list.main(Unknown Source)
>> Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
>> at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
>> at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
>> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
>> ... 8 more
>> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
>> at java.net <http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>>
>>
>> Here is my nimbus storm.yaml
>>
>> nimbus.seeds:
>> - "130.211.53.188"
>> nimbus.thrift.port: 6627
>> storm.local.dir: /var/storm-dir
>> storm.zookeeper.servers:
>> - "104.199.7.70"
>> ui.host: 0.0.0.0
>> ui.port: 8080
>> supervisor.slots.ports:
>> - 6700
>> - 6701
>> - 6702
>> - 6703
>>
>> My client storm uses the same nimbus host line:
>>
>> nimbus.seeds:
>> - “130.211.53.188”
>>
>> Not sure why i can’t connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
>>
>> Thanks for the help
>>
>>
>
Re: Cant connect to remote cluster
Posted by Ohad Edelstein <oh...@mintigo.com>.
Did you try running the command, from the same machine?
From: Al Hennessey <al...@gmail.com>>
Reply-To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Date: Saturday, 19 November 2016 at 0:10
To: "user@storm.apache.org<ma...@storm.apache.org>" <us...@storm.apache.org>>
Subject: Re: Cant connect to remote cluster
Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
Just to let you know that i am on a mac
Thanks for the help
On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com>> wrote:
m new to storm but let's try that and I hope it will work
Check the file which has definitions of IP
It exists in this path
/ets/hosts it should contains like 127.0.x.x mydomain
1- Check that 130.211.53.188 has domain name or it already exists or
2-If you found it try to use the domain name instead of IP address
On Friday, November 18, 2016, Al Hennessey <al...@gmail.com>> wrote:
Hi, i am having an issue connecting to my remote clustered storm server, when i try running "storm list" i get this error
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
at org.apache.storm.command.list$_main.invoke(list.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:152)
at clojure.lang.AFn.applyTo(AFn.java:144)
at org.apache.storm.command.list.main(Unknown Source)
Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
... 8 more
Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
at java.net<http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
Here is my nimbus storm.yaml
nimbus.seeds:
- "130.211.53.188"
nimbus.thrift.port: 6627
storm.local.dir: /var/storm-dir
storm.zookeeper.servers:
- "104.199.7.70"
ui.host: 0.0.0.0
ui.port: 8080
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
My client storm uses the same nimbus host line:
nimbus.seeds:
- "130.211.53.188"
Not sure why i can't connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
Thanks for the help
Re: Cant connect to remote cluster
Posted by Mostafa Gomaa <mg...@trendak.com>.
Can you telnet the ip on 6627 from your local machine?
On Nov 19, 2016 12:11 AM, "Al Hennessey" <al...@gmail.com> wrote:
Hi, i thanks for the reply, i added the ip to my hosts file with a domain
name, but it still did not work and threw the same error
Just to let you know that i am on a mac
Thanks for the help
On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
m new to storm but let's try that and I hope it will work
Check the file which has definitions of IP
It exists in this path
/ets/hosts it should contains like 127.0.x.x mydomain
1- Check that 130.211.53.188 has domain name or it already exists or
2-If you found it try to use the domain name instead of IP address
On Friday, November 18, 2016, Al Hennessey <al...@gmail.com> wrote:
> Hi, i am having an issue connecting to my remote clustered storm server,
> when i try running “storm list” i get this error
>
> Exception in thread "main" java.lang.RuntimeException:
> org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.security.auth.TBackoffConnect.retryNext(
> TBackoffConnect.java:64)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
> Retry(TBackoffConnect.java:56)
> at org.apache.storm.security.auth.ThriftClient.reconnect(Thrift
> Client.java:99)
> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftCli
> ent.java:69)
> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Ni
> mbusClient.java:78)
> at org.apache.storm.command.list$_main.invoke(list.clj:22)
> at clojure.lang.AFn.applyToHelper(AFn.java:152)
> at clojure.lang.AFn.applyTo(AFn.java:144)
> at org.apache.storm.command.list.main(Unknown Source)
> Caused by: org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
> at org.apache.storm.thrift.transport.TFramedTransport.open(
> TFramedTransport.java:81)
> at org.apache.storm.security.auth.SimpleTransportPlugin.connect
> (SimpleTransportPlugin.java:103)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWith
> Retry(TBackoffConnect.java:53)
> ... 8 more
> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
> Impl.java:184)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>
>
> Here is my nimbus storm.yaml
>
> nimbus.seeds:
> - "130.211.53.188"
> nimbus.thrift.port: 6627
> storm.local.dir: /var/storm-dir
> storm.zookeeper.servers:
> - "104.199.7.70"
> ui.host: 0.0.0.0
> ui.port: 8080
> supervisor.slots.ports:
> - 6700
> - 6701
> - 6702
> - 6703
>
> My client storm uses the same nimbus host line:
>
> nimbus.seeds:
> - “130.211.53.188”
>
> Not sure why i can’t connect, i am running on google cloud platform and
> all my ports are open so it should be able to talk to each other.
>
> Thanks for the help
>
>
>
Re: Cant connect to remote cluster
Posted by Al Hennessey <al...@gmail.com>.
Hi, i thanks for the reply, i added the ip to my hosts file with a domain name, but it still did not work and threw the same error
Just to let you know that i am on a mac
Thanks for the help
> On 18 Nov 2016, at 22:01, sam mohel <sa...@gmail.com> wrote:
>
> m new to storm but let's try that and I hope it will work
> Check the file which has definitions of IP
> It exists in this path
> /ets/hosts it should contains like 127.0.x.x mydomain
> 1- Check that 130.211.53.188 has domain name or it already exists or
> 2-If you found it try to use the domain name instead of IP address
> On Friday, November 18, 2016, Al Hennessey <alhennessey92@gmail.com <ma...@gmail.com>> wrote:
> Hi, i am having an issue connecting to my remote clustered storm server, when i try running “storm list” i get this error
>
> Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
> at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
> at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
> at org.apache.storm.command.list$_main.invoke(list.clj:22)
> at clojure.lang.AFn.applyToHelper(AFn.java:152)
> at clojure.lang.AFn.applyTo(AFn.java:144)
> at org.apache.storm.command.list.main(Unknown Source)
> Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
> at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
> at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:103)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53)
> ... 8 more
> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at java.net <http://java.net/>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>
>
> Here is my nimbus storm.yaml
>
> nimbus.seeds:
> - "130.211.53.188"
> nimbus.thrift.port: 6627
> storm.local.dir: /var/storm-dir
> storm.zookeeper.servers:
> - "104.199.7.70"
> ui.host: 0.0.0.0
> ui.port: 8080
> supervisor.slots.ports:
> - 6700
> - 6701
> - 6702
> - 6703
>
> My client storm uses the same nimbus host line:
>
> nimbus.seeds:
> - “130.211.53.188”
>
> Not sure why i can’t connect, i am running on google cloud platform and all my ports are open so it should be able to talk to each other.
>
> Thanks for the help
>
>
Re: Cant connect to remote cluster
Posted by sam mohel <sa...@gmail.com>.
m new to storm but let's try that and I hope it will work
Check the file which has definitions of IP
It exists in this path
/ets/hosts it should contains like 127.0.x.x mydomain
1- Check that 130.211.53.188 has domain name or it already exists or
2-If you found it try to use the domain name instead of IP address
On Friday, November 18, 2016, Al Hennessey <al...@gmail.com> wrote:
> Hi, i am having an issue connecting to my remote clustered storm server,
> when i try running “storm list” i get this error
>
> Exception in thread "main" java.lang.RuntimeException:
> org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.security.auth.TBackoffConnect.
> retryNext(TBackoffConnect.java:64)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(
> TBackoffConnect.java:56)
> at org.apache.storm.security.auth.ThriftClient.reconnect(
> ThriftClient.java:99)
> at org.apache.storm.security.auth.ThriftClient.<init>(
> ThriftClient.java:69)
> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(
> NimbusClient.java:78)
> at org.apache.storm.command.list$_main.invoke(list.clj:22)
> at clojure.lang.AFn.applyToHelper(AFn.java:152)
> at clojure.lang.AFn.applyTo(AFn.java:144)
> at org.apache.storm.command.list.main(Unknown Source)
> Caused by: org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
> at org.apache.storm.thrift.transport.TFramedTransport.
> open(TFramedTransport.java:81)
> at org.apache.storm.security.auth.SimpleTransportPlugin.
> connect(SimpleTransportPlugin.java:103)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(
> TBackoffConnect.java:53)
> ... 8 more
> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:
> 184)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>
>
> Here is my nimbus storm.yaml
>
> nimbus.seeds:
> - "130.211.53.188"
> nimbus.thrift.port: 6627
> storm.local.dir: /var/storm-dir
> storm.zookeeper.servers:
> - "104.199.7.70"
> ui.host: 0.0.0.0
> ui.port: 8080
> supervisor.slots.ports:
> - 6700
> - 6701
> - 6702
> - 6703
>
> My client storm uses the same nimbus host line:
>
> nimbus.seeds:
> - “130.211.53.188”
>
> Not sure why i can’t connect, i am running on google cloud platform and
> all my ports are open so it should be able to talk to each other.
>
> Thanks for the help
>
>
>
Re: Cant connect to remote cluster
Posted by Joaquin Menchaca <jm...@gobalto.com>.
What version of Storm are you running? What is the header information from
the storm list, not just the exception.
On Fri, Nov 18, 2016 at 1:27 PM, Al Hennessey <al...@gmail.com>
wrote:
> Hi, i am having an issue connecting to my remote clustered storm server,
> when i try running “storm list” i get this error
>
> Exception in thread "main" java.lang.RuntimeException:
> org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.security.auth.TBackoffConnect.
> retryNext(TBackoffConnect.java:64)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(
> TBackoffConnect.java:56)
> at org.apache.storm.security.auth.ThriftClient.reconnect(
> ThriftClient.java:99)
> at org.apache.storm.security.auth.ThriftClient.<init>(
> ThriftClient.java:69)
> at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
> at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(
> NimbusClient.java:78)
> at org.apache.storm.command.list$_main.invoke(list.clj:22)
> at clojure.lang.AFn.applyToHelper(AFn.java:152)
> at clojure.lang.AFn.applyTo(AFn.java:144)
> at org.apache.storm.command.list.main(Unknown Source)
> Caused by: org.apache.storm.thrift.transport.TTransportException:
> java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226)
> at org.apache.storm.thrift.transport.TFramedTransport.
> open(TFramedTransport.java:81)
> at org.apache.storm.security.auth.SimpleTransportPlugin.
> connect(SimpleTransportPlugin.java:103)
> at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(
> TBackoffConnect.java:53)
> ... 8 more
> Caused by: java.net.UnknownHostException: nimbus-dev.c.epic-dev.internal
> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:
> 184)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
>
>
> Here is my nimbus storm.yaml
>
> nimbus.seeds:
> - "130.211.53.188"
> nimbus.thrift.port: 6627
> storm.local.dir: /var/storm-dir
> storm.zookeeper.servers:
> - "104.199.7.70"
> ui.host: 0.0.0.0
> ui.port: 8080
> supervisor.slots.ports:
> - 6700
> - 6701
> - 6702
> - 6703
>
> My client storm uses the same nimbus host line:
>
> nimbus.seeds:
> - “130.211.53.188”
>
> Not sure why i can’t connect, i am running on google cloud platform and
> all my ports are open so it should be able to talk to each other.
>
> Thanks for the help
>
>
>
--
是故勝兵先勝而後求戰，敗兵先戰而後求勝。