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 <jak...@gmail.com> wrote: > > From: Jake Luciani <jak...@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 <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 > <cassandra.yaml>
