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
