cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aaron morton <aa...@thelastpickle.com>
Subject Re: Reg File upload to cassandra - connection refused error
Date Thu, 18 Aug 2011 22:30:04 GMT
Are you using  0.0.0.0 in your mapred config ? It should be the external IP of the cassandra
node. 

0.0.0.0 is just for the rpc_address config. 

Cheers
 
-----------------
Aaron Morton
Freelance Cassandra Developer
@aaronmorton
http://www.thelastpickle.com

On 19/08/2011, at 3:35 AM, Thamizh wrote:

> 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
> <cassandra.yaml>


Mime
View raw message