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 C005E109BE for ; Mon, 9 Dec 2013 02:01:04 +0000 (UTC) Received: (qmail 24977 invoked by uid 500); 9 Dec 2013 02:01:02 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 24952 invoked by uid 500); 9 Dec 2013 02:01:01 -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 24944 invoked by uid 99); 9 Dec 2013 02:01:01 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 Dec 2013 02:01:01 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of parthpatil@gmail.com designates 209.85.214.175 as permitted sender) Received: from [209.85.214.175] (HELO mail-ob0-f175.google.com) (209.85.214.175) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 Dec 2013 02:00:57 +0000 Received: by mail-ob0-f175.google.com with SMTP id uz6so3072844obc.20 for ; Sun, 08 Dec 2013 18:00:37 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=JiduIPfy1jPk4BS5VCS0QcE2r8lzWorr7190RGG4hYk=; b=Op7ljmrVfkbJ38bSQuED+od2S9wAdHAZrNEcaWDD8KjgdYyd9FG6zv+2bdpZkWgIgv jIwR36hoz1cl56rOAsLK7wAxzfPg+bitumUNOBkyyzoaQWueNGA6Q1nXadwWXrdBVyrH YpsqbbhEsZXgfViSMo47nee++b781dIfsNvZ4aX/GSiJvCB8BomJpYAHIMdNv47Kt5JG HXzh7Vw7agqXFGMe8+Dd2GoVjz4S+2bsjwUb1vL41J2DF2Ch3SZLtFmw0tpEmHPPhxMo zEgfqbK71iqwIz2kZME0q7zxqIe5dcy3mVaLhFF+ucfav4JK9goOJgMIUQgIXBo3OIe5 2Srw== MIME-Version: 1.0 X-Received: by 10.182.246.7 with SMTP id xs7mr18306obc.81.1386554437158; Sun, 08 Dec 2013 18:00:37 -0800 (PST) Received: by 10.76.141.232 with HTTP; Sun, 8 Dec 2013 18:00:37 -0800 (PST) In-Reply-To: <04CAD34D-F501-4D78-9321-7987E1BB4C75@thelastpickle.com> References: <04CAD34D-F501-4D78-9321-7987E1BB4C75@thelastpickle.com> Date: Sun, 8 Dec 2013 18:00:37 -0800 Message-ID: Subject: Re: Unable to run hadoop_cql3_word_count examples From: Parth Patil To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=001a11c2fa06b04d3704ed105c51 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c2fa06b04d3704ed105c51 Content-Type: text/plain; charset=ISO-8859-1 Hi Aaron, Thanks for your response. I didn't make any change to the code when I got that exception. I just ran the example as is after I cloned the repo from github. I did a git pull today on cassandra-2.0 branch, built via ant and re-ran the example and now I am not getting the error from before but I am now getting the following error as shown in this gist https://gist.github.com/parth-patil/7864738 On Sun, Dec 8, 2013 at 11:30 AM, Aaron Morton wrote: > InvalidRequestException(why:consistency level LOCAL_ONE not compatible > with replication strategy (org.apache.cassandra.locator.SimpleStrategy)) at > > The LOCAL_ONE consistency level can only be used with the > NetworkTopologyStrategy. > > I had a quick look and the code does not use LOCAL_ONE, did you make a > change? > > Cheers > > ----------------- > Aaron Morton > New Zealand > @aaronmorton > > Co-Founder & Principal Consultant > Apache Cassandra Consulting > http://www.thelastpickle.com > > On 3/12/2013, at 10:03 pm, Parth Patil wrote: > > Hi, > I am new to Cassandra and I am exploring the Hadoop integration > (MapReduce) provided by Cassandra. > > I am trying to run the hadoop examples provided in the cassandra's repo > under examples/hadoop_cql3_word_count. I am using the cassandra-2.0 branch. > I have a single node cassandra running locally. I was able to run the > ./bin/word_count_setup step successfully but when I run the > ./bin/word_count step I am getting the following error : > > java.lang.RuntimeException at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:661) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.(CqlPagingRecordReader.java:297) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:163) > at > org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initialize(MapTask.java:522) > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:763) at > org.apache.hadoop.mapred.MapTask.run(MapTask.java:370) at > org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) > Caused by: InvalidRequestException(why:consistency level LOCAL_ONE not > compatible with replication strategy > (org.apache.cassandra.locator.SimpleStrategy)) at > org.apache.cassandra.thrift.Cassandra$execute_prepared_cql3_query_result$execute_prepared_cql3_query_resultStandardScheme.read(Cassandra.java:52627) > at > org.apache.cassandra.thrift.Cassandra$execute_prepared_cql3_query_result$execute_prepared_cql3_query_resultStandardScheme.read(Cassandra.java:52604) > at > org.apache.cassandra.thrift.Cassandra$execute_prepared_cql3_query_result.read(Cassandra.java:52519) > at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) at > org.apache.cassandra.thrift.Cassandra$Client.recv_execute_prepared_cql3_query(Cassandra.java:1785) > at > org.apache.cassandra.thrift.Cassandra$Client.execute_prepared_cql3_query(Cassandra.java:1770) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:631) > ... 6 more > ------------------------------ > > Has anyone seen this before ? Am I missing something ? > > -- > Best, > Parth > > > -- Best, Parth --001a11c2fa06b04d3704ed105c51 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi Aaron,
Thanks for your response. I didn't make = any change to the code when I got that exception. I just ran the example as= is after I cloned the repo from github.

I did a g= it pull today on cassandra-2.0 branch, built via ant and re-ran the example= and now I am not getting the error from before but I am now getting the fo= llowing error as shown in this gist=A0




On Sun, D= ec 8, 2013 at 11:30 AM, Aaron Morton <aaron@thelastpickle.com>= ; wrote:

InvalidRequestException(why:consistency level LOCAL_ONE not compatible with= replication strategy (org.apache.cassandra.locator.SimpleStrategy)) at=A0<= /p>


The LOCAL_ONE consistency level = can only be used with the NetworkTopologyStrategy.=A0

I had a quick look and the code does not use LOCAL_ONE, did = you make a change?

Cheers
=A0
=
-----------------
Aaron Morton
New Zealand
@aaronmorton

Co-Founder & Principal Consult= ant
Apache Cassandra Consulting

On 3/12/2013, at 10:03 pm, Parth Patil <parthpatil@gmail.com> wrote:=

Hi,
I am new to Ca= ssandra and I am exploring the Hadoop integration (MapReduce) provided by C= assandra.

I am trying to run the hadoop examples provided in the cassandra's repo= under examples/hadoop_cql3_word_count. I am using the cassandra-2.0 branch= . I have a single node cassandra running locally. I was able to run the ./b= in/word_count_setup step successfully but when I run the ./bin/word_count s= tep I am getting the following error :

java.lang.RuntimeException at org.apache.cassandra.hadoop.cql3.CqlPagingRec= ordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:661) at org.a= pache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.(CqlPagingRec= ordReader.java:297) at org.apache.cassandra.hadoop.cql3.CqlPagingRecordRead= er.initialize(CqlPagingRecordReader.java:163) at org.apache.hadoop.mapred.M= apTask$NewTrackingRecordReader.initialize(MapTask.java:522) at org.apache.h= adoop.mapred.MapTask.runNewMapper(MapTask.java:763) at org.apache.hadoop.ma= pred.MapTask.run(MapTask.java:370) at org.apache.hadoop.mapred.LocalJobRunn= er$Job.run(LocalJobRunner.java:212) Caused by: InvalidRequestException(why:= consistency level LOCAL_ONE not compatible with replication strategy (org.a= pache.cassandra.locator.SimpleStrategy)) at org.apache.cassandra.thrift.Cas= sandra$execute_prepared_cql3_query_result$execute_prepared_cql3_query_resul= tStandardScheme.read(Cassandra.java:52627) at org.apache.cassandra.thrift.C= assandra$execute_prepared_cql3_query_result$execute_prepared_cql3_query_res= ultStandardScheme.read(Cassandra.java:52604) at org.apache.cassandra.thrift= .Cassandra$execute_prepared_cql3_query_result.read(Cassandra.java:52519) at= org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) at or= g.apache.cassandra.thrift.Cassandra$Client.recv_execute_prepared_cql3_query= (Cassandra.java:1785) at org.apache.cassandra.thrift.Cassandra$Client.execu= te_prepared_cql3_query(Cassandra.java:1770) at org.apache.cassandra.hadoop.= cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.j= ava:631) ... 6 more

Has anyone seen this before ? Am I missing something ?


--=
Best,
Parth




--
Best,
Parth
--001a11c2fa06b04d3704ed105c51--