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
Description: Binary data
