Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 12DCB8AF9 for ; Thu, 18 Aug 2011 13:04:18 +0000 (UTC) Received: (qmail 98808 invoked by uid 500); 18 Aug 2011 13:04:15 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 98724 invoked by uid 500); 18 Aug 2011 13:04:14 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 98716 invoked by uid 99); 18 Aug 2011 13:04:14 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Aug 2011 13:04:14 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of jakers@gmail.com designates 209.85.213.44 as permitted sender) Received: from [209.85.213.44] (HELO mail-yw0-f44.google.com) (209.85.213.44) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Aug 2011 13:04:07 +0000 Received: by ywm21 with SMTP id 21so1522369ywm.31 for ; Thu, 18 Aug 2011 06:03:46 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type; bh=CSFFE86jsK3vvyZz1Mm2X+C3aBvRkvgZ1ld1vSpJxww=; b=BYARyA5m9dmbClP6OKIyALEyf99PlTQNXEr73YcVySusdvsgmgsM7za85q7ONBV2DY 84W47hevoWHXXctyIHI/zGRHqHUnSFRwW8D2wdHT7JJn2F55BBnNX5zdixkrYDC6RKzt Z6COXADSb8iE6tUOHs4R1HS0fpS9sKv0x8W+8= Received: by 10.142.179.6 with SMTP id b6mr374516wff.238.1313672626152; Thu, 18 Aug 2011 06:03:46 -0700 (PDT) MIME-Version: 1.0 Received: by 10.142.148.13 with HTTP; Thu, 18 Aug 2011 06:03:26 -0700 (PDT) In-Reply-To: <1313671035.74757.YahooMailClassic@web95312.mail.in2.yahoo.com> References: <1313671035.74757.YahooMailClassic@web95312.mail.in2.yahoo.com> From: Jake Luciani Date: Thu, 18 Aug 2011 09:03:26 -0400 Message-ID: Subject: Re: Reg File upload to cassandra - connection refused error To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=000e0cd152ca3ba6c604aac73ec9 X-Virus-Checked: Checked by ClamAV on apache.org --000e0cd152ca3ba6c604aac73ec9 Content-Type: text/plain; charset=ISO-8859-1 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 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 --000e0cd152ca3ba6c604aac73ec9 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable What is rpc_address set to in cassandra.yaml?

Try settin= g 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 worki= ng fine on single node.

1. Here are configuration steps that has been updated on "cassandr= a.yaml"
seeds: "lab02,lab03,lab04"
listen_address:
=
2. KS & CF creation commands,
create keyspace info_table
=A0=A0=A0 with placement_strategy =3D 'org.apache.cassandra.locator.Sim= pleStrategy'
=A0=A0=A0 and strategy_options =3D [{replication_factor= :3}];
use ip_info_table;
create column family info_0 with comparator = =3D UTF8Type and subcomparator =3D UTF8Type and column_type =3D 'Super&= #39; and key_validation_class =3D UTF8Type;

3. Error:
11/08/18 04:50:08 INFO mapred.JobClient:=A0 = map 100% reduce 0%
11/08/18 04:50:21 INFO mapred.JobClient:=A0 map 100% = reduce 11%
11/08/18 04:50:24 INFO mapred.JobClient:=A0 map 100% reduce 2= 2%
11/08/18 04:50:30 INFO mapred.JobClient:=A0 map 100% reduce 33%
11/08/18= 04:50:33 INFO mapred.JobClient:=A0 map 100% reduce 66%
11/08/18 04:50:3= 9 INFO mapred.JobClient: Task Id : attempt_201104211044_0702_r_000000_2, St= atus : FAILED
java.io.IOException: org.apache.thrift.transport.TTransportException: java.= net.ConnectException: Connection refused
=A0=A0 =A0at org.apache.cassand= ra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter= .java:329)
Caused by: org.apache.thrift.transport.TTransportException: java.net.Connec= tException: Connection refused
=A0=A0 =A0at org.apache.thrift.transport.= TSocket.open(TSocket.java:183)
=A0=A0 =A0at org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.createAuthenticatedCl= ient(ColumnFamilyOutputFormat.java:152)
=A0=A0 =A0at org.apache.cassandr= a.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.= java:320)
Caused by: java.net.ConnectException: Connection refused
=A0=A0 =A0at ja= va.net.PlainSocketImpl.socketConnect(Native Method)
=A0=A0 =A0at java.ne= t.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
=A0=A0 =A0at java.= net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
=A0=A0 =A0at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
= =A0=A0 =A0at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
= =A0=A0 =A0at java.net.Socket.connect(Socket.java:525)
=A0=A0 =A0at org.a= pache.thrift.transport.TSocket.open(TSocket.java:178)

When I issued "bin/nodetool -h localhost ring" command, it di= splays all the nodes.

Kindly help me to resolve the issue.

Regards,
Tha= mizhannal



--
http://twitter.com/tjake
--000e0cd152ca3ba6c604aac73ec9--