What is rpc_address set to in cassandra.yaml?
Try setting these to 0.0.0.0 to be sure it's listening to external traffic.
On Thu, Aug 18, 2011 at 8:37 AM, Thamizh <tceg...@yahoo.co.in> wrote:
> Hi All,
>
> This is regarding help to resolve "connection refused error" on Cassandra
> client API.
>
> I have installed cassandra-0.8.4 on three machines and tried to upload a
> file from HDFS to Cassandra by Hadoop map-reduce program and have caught up
> "connection refused" error.
>
> But, the same code is working fine on single node.
>
> 1. Here are configuration steps that has been updated on "cassandra.yaml"
> seeds: "lab02,lab03,lab04"
> listen_address:
>
> 2. KS & CF creation commands,
> create keyspace info_table
> with placement_strategy = 'org.apache.cassandra.locator.SimpleStrategy'
> and strategy_options = [{replication_factor:3}];
> use ip_info_table;
> create column family info_0 with comparator = UTF8Type and subcomparator =
> UTF8Type and column_type = 'Super' and key_validation_class = UTF8Type;
>
> 3. Error:
> 11/08/18 04:50:08 INFO mapred.JobClient: map 100% reduce 0%
> 11/08/18 04:50:21 INFO mapred.JobClient: map 100% reduce 11%
> 11/08/18 04:50:24 INFO mapred.JobClient: map 100% reduce 22%
> 11/08/18 04:50:30 INFO mapred.JobClient: map 100% reduce 33%
> 11/08/18 04:50:33 INFO mapred.JobClient: map 100% reduce 66%
> 11/08/18 04:50:39 INFO mapred.JobClient: Task Id :
> attempt_201104211044_0702_r_000000_2, Status : FAILED
> java.io.IOException: org.apache.thrift.transport.TTransportException:
> java.net.ConnectException: Connection refused
> at
> org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:329)
> Caused by: org.apache.thrift.transport.TTransportException:
> java.net.ConnectException: Connection refused
> at org.apache.thrift.transport.TSocket.open(TSocket.java:183)
> at
> org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.createAuthenticatedClient(ColumnFamilyOutputFormat.java:152)
> at
> org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:320)
> Caused by: java.net.ConnectException: Connection refused
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
> at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
> at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
> at java.net.Socket.connect(Socket.java:525)
> at org.apache.thrift.transport.TSocket.open(TSocket.java:178)
>
> When I issued "bin/nodetool -h localhost ring" command, it displays all the
> nodes.
>
> Kindly help me to resolve the issue.
>
> Regards,
> Thamizhannal
--
http://twitter.com/tjake
