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 2C81BE0AC for ; Fri, 1 Feb 2013 10:57:25 +0000 (UTC) Received: (qmail 27229 invoked by uid 500); 1 Feb 2013 10:57:22 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 27153 invoked by uid 500); 1 Feb 2013 10:57:19 -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 27119 invoked by uid 99); 1 Feb 2013 10:57:18 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Feb 2013 10:57:18 +0000 X-ASF-Spam-Status: No, hits=-0.5 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of jeremy.hanna1234@gmail.com designates 209.85.212.175 as permitted sender) Received: from [209.85.212.175] (HELO mail-wi0-f175.google.com) (209.85.212.175) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Feb 2013 10:57:08 +0000 Received: by mail-wi0-f175.google.com with SMTP id hq12so410198wib.14 for ; Fri, 01 Feb 2013 02:56:48 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=x-received:content-type:mime-version:subject:from:in-reply-to:date :content-transfer-encoding:message-id:references:to:x-mailer; bh=CAhNMVQfWHghl73hJngS5EOklDejspg77gcqaq/ShiA=; b=AlqT051h56odjPpBKqz1urypZLjMZdn1VQ03mUzfF6QvpjquQbixFWdN7mTQHaEMgX b+vrHRefOIICpnOhciESA94NUlbjJxBbnq8Mmpq1trGw3iewmbe4n+O4CQkGOpx541GE hrf+lEQfcKlPgZk56Ilwifm4MPUI8rcAJaIsveP6FRtaCATmrkgSkFhNcNiEC5EYIzOj 4Ogjx1ngANnmFtSiXOX9iHeaa9oCH+bwHG6PEKF5GO2UvEc/ykinMAf9cEv2toplflS6 qN/lM4S7rVqttBjQCJ5IPLBUn5kOoKc5FzgRJyhZ7QX2eCpJb9hEtuu/sI4yDNHv4kHq s3ow== X-Received: by 10.194.178.33 with SMTP id cv1mr20742002wjc.46.1359716208419; Fri, 01 Feb 2013 02:56:48 -0800 (PST) Received: from [10.0.250.5] (host-80-195-152-110.static.cable.virginmedia.com. [80.195.152.110]) by mx.google.com with ESMTPS id hb9sm2447860wib.3.2013.02.01.02.56.47 (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Fri, 01 Feb 2013 02:56:47 -0800 (PST) Content-Type: text/plain; charset=iso-8859-1 Mime-Version: 1.0 (Mac OS X Mail 6.2 \(1499\)) Subject: Re: Start token sorts after end token From: Jeremy Hanna In-Reply-To: Date: Fri, 1 Feb 2013 10:56:54 +0000 Content-Transfer-Encoding: quoted-printable Message-Id: References: To: user@cassandra.apache.org X-Mailer: Apple Mail (2.1499) X-Virus-Checked: Checked by ClamAV on apache.org See https://issues.apache.org/jira/browse/CASSANDRA-5168 - should be = fixed in 1.1.10 and 1.2.2. On Jan 30, 2013, at 9:18 AM, Tejas Patil = wrote: > While reading data from Cassandra in map-reduce, I am getting = "InvalidRequestException(why:Start token sorts after end token)" >=20 > Below is the code snippet that I used and the entire stack trace. > (I am using Cassandra 1.2.0 and hadoop 0.20.2) > Can you point out the issue here ? >=20 > Code snippet: > SlicePredicate predicate =3D new SlicePredicate(); >=20 > SliceRange sliceRange =3D new SliceRange(); > sliceRange.start =3D ByteBuffer.wrap(("1".getBytes())); > sliceRange.finish =3D ByteBuffer.wrap(("1000000".getBytes())); > sliceRange.reversed =3D false; > // predicate.slice_range =3D sliceRange; >=20 > List colNames =3D new ArrayList(); > colNames.add(ByteBuffer.wrap("url".getBytes())); > colNames.add(ByteBuffer.wrap("Parent".getBytes())); > predicate.column_names =3D colNames; >=20 > ConfigHelper.setInputSlicePredicate(job.getConfiguration(), = predicate); >=20 > Full stack trace: > java.lang.RuntimeException: InvalidRequestException(why:Start token = sorts after end token) > at = org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.may= beInit(ColumnFamilyRecordReader.java:384) > at = org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.com= puteNext(ColumnFamilyRecordReader.java:390) > at = org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.com= puteNext(ColumnFamilyRecordReader.java:313) > at = com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterat= or.java:143) > at = com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:1= 38) > at = org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFa= milyRecordReader.java:184) > at = org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapT= ask.java:456) > at = org.apache.hadoop.mapreduce.MapContext.nextKeyValue(MapContext.java:67) > at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:143) > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java: >=20