incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thamizh <tceg...@yahoo.co.in>
Subject Re: Reg File upload to cassandra - connection refused error
Date Thu, 18 Aug 2011 15:35:01 GMT
Hi Jake,

Thanks a lot.

I have done the below modification as you pointed out. 

Once, I do the modification on cassandra.yaml does it require to restart the cassandra service?

Now, I am getting below error, (attached cassandra.yaml)

11/08/18 10:35:18 INFO mapred.JobClient:  map 100% reduce 0%
11/08/18 10:35:20 INFO mapred.JobClient: Task Id : attempt_201104211044_0712_r_000000_2, Status
: FAILED
Error: java.net.UnknownHostException: /0.0.0.0
    at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
    at java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:849)
    at java.net.InetAddress.getAddressFromNameService(InetAddress.java:1200)
    at java.net.InetAddress.getAllByName0(InetAddress.java:1153)
    at java.net.InetAddress.getAllByName(InetAddress.java:1083)
    at java.net.InetAddress.getAllByName(InetAddress.java:1019)
    at java.net.InetAddress.getByName(InetAddress.java:969)
    at org.apache.cassandra.client.RingCache.refreshEndpointMap(RingCache.java:93)
    at org.apache.cassandra.client.RingCache.<init>(RingCache.java:67)
    at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.<init>(ColumnFamilyRecordWriter.java:98)
    at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.<init>(ColumnFamilyRecordWriter.java:92)
    at org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.getRecordWriter(ColumnFamilyOutputFormat.java:132)
    at org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.getRecordWriter(ColumnFamilyOutputFormat.java:62)
    at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:553)
    at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:408)
    at org.apache.hadoop.mapred.Child.main(Child.java:170)


Regards,

  Thamizhannal P

--- On Thu, 18/8/11, Jake Luciani <jakers@gmail.com> wrote:

From: Jake Luciani <jakers@gmail.com>
Subject: Re: Reg File upload to cassandra - connection refused error
To: user@cassandra.apache.org
Date: Thursday, 18 August, 2011, 6:33 PM

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 <tcegrid@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





Mime
View raw message