storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jungtaek Lim <kabh...@gmail.com>
Subject Re: Connection refused when trying to connect to nimbus
Date Mon, 10 Oct 2016 10:03:31 GMT
Hi Mostafa,

What's your Storm version?

- Jungtaek Lim (HeartSaVioR)

2016년 10월 10일 (월) 오후 6:59, Mostafa Gomaa <mgomaa@trendak.com>님이 작성:

Hello All,

I have a single node cluster running zookeeper and nimbus on a remote
machine. Both zookeeper and nimbus are running and I can use the storm
client script successfully from within the machine. However, when I tried
to list or submit topologies from a remote machine, I get the following
error:

Exception in thread "main" java.lang.RuntimeException:
org.apache.storm.thrift.transport.TTransportException:
java.net.ConnectException: Connection refused
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.ConnectException: Connection refused
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.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:579)
at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221)
... 11 more


I don't think it's an iptables issue since I can telnet to the remote
machine on both zookeeper and nimbus ports. My storm.yaml files are shown
below:

on client machine:

storm.zookeeper.servers:
     - "192.168.3.115"

nimbus.seeds: ["192.168.3.115"]


on nimbus/zookeeper machine:

storm.zookeeper.servers:
     - "localhost"

nimbus.seeds: ["localhost"]
storm.local.dir: "/mnt/storm"


Any help would be greatly appreciated

Mime
View raw message