Error in NodeAutoDiscoverService for trying to connect to different ethernet address

38 views
Skip to first unread message

varun tahin

unread,
Aug 26, 2013, 4:01:42 AM8/26/13
to hector...@googlegroups.com
Dear Members,

Does Cassandra support the feature to give different ethernet addresses of same server in listen address and rpc address , so as to distribute communication load(listen) and data load(RPC)?

The configuration kept in YAML file is as follows:
Same addresses for listen address and seeds
Rpc address and host address on client side  is kept same.


The cluster is running fine on Cassandra start, but is giving exception on client connection.

[Hector.me.prettyprint.cassandra.connection.NodeAutoDiscoverService-1] ERROR me.prettyprint.cassandra.connection.HConnectionManager  - Transport exception host to HConnectionManager: 172.17.128.22(172.17.128.22):9160
me.prettyprint.hector.api.exceptions.HectorTransportException: Unable to open transport to 172.17.128.22(172.17.128.22):9160 , java.net.ConnectException: Connection refused
        at me.prettyprint.cassandra.connection.client.HThriftClient.open(HThriftClient.java:180)
        at me.prettyprint.cassandra.connection.client.HThriftClient.open(HThriftClient.java:38)
        at me.prettyprint.cassandra.connection.ConcurrentHClientPool.createClient(ConcurrentHClientPool.java:162)
        at me.prettyprint.cassandra.connection.ConcurrentHClientPool.<init>(ConcurrentHClientPool.java:53)
        at me.prettyprint.cassandra.connection.LeastActiveBalancingPolicy.createConnection(LeastActiveBalancingPolicy.java:59)
        at me.prettyprint.cassandra.connection.HConnectionManager.addCassandraHost(HConnectionManager.java:112)
        at me.prettyprint.cassandra.connection.NodeAutoDiscoverService.doAddNodes(NodeAutoDiscoverService.java:74)
        at me.prettyprint.cassandra.connection.NodeAutoDiscoverService$QueryRing.run(NodeAutoDiscoverService.java:59)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
        at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
        at org.apache.thrift.transport.TSocket.open(TSocket.java:185)
        at org.apache.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
        at me.prettyprint.cassandra.connection.client.HThriftClient.open(HThriftClient.java:174)
        ... 16 more
Caused by: java.net.ConnectException: Connection refused
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351)
        at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
        at java.net.Socket.connect(Socket.java:529)
        at org.apache.thrift.transport.TSocket.open(TSocket.java:180)
        ... 18 more

Kindly help in solving the same 

Thanks
Varun Tahin
NO-SQL developer
RJIL(Reliance Industries)

Reply all
Reply to author
Forward
0 new messages