Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (nike.apache.org: domain of jeremy.hanna1234@gmail.com
 designates 209.85.161.172 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=content-type:mime-version:subject:from:in-reply-to:date
         :content-transfer-encoding:message-id:references:to:x-mailer;
        b=HITvreFIt2N/1YOZhxwYnmjtSvrd88Oy85g2yxiFXv3MoJFdOBWZCiMAkbLmqKDGzK
         Im6Z83zdbtZBTJ8Xy+tScqiPQpVz2NwXKCn9Z8Stb82dAj8sd2XOTHfNghWy1MxxxmVs
         BEkjKl8Ex6EXpQ91Gl53cCOoNe1CWyDz72bHY=
Content-Type: text/plain; charset=us-ascii
Mime-Version: 1.0 (Apple Message framework v1081)
Subject: Re: MapReduce/Hadoop in cassandra 0.7 beta3
From: Jeremy Hanna <jeremy.hanna1234@gmail.com>
In-Reply-To: <B6960A109BFD6E44B09EED4E31DD7FF27B6D@MOES1.nisc.lan>
Date: Wed, 10 Nov 2010 11:40:42 -0600
Content-Transfer-Encoding: quoted-printable
Message-Id: <913E79D2-7D19-407D-A307-BA64AD687D0F@gmail.com>
References: <B6960A109BFD6E44B09EED4E31DD7FF27B6D@MOES1.nisc.lan>
To: user@cassandra.apache.org

Aditya,

Can you reproduce the problem locally with "pig -x local myscript.pig"?

Also, moving this message back to the cassandra user list.

On Nov 10, 2010, at 10:47 AM, Aditya Muralidharan wrote:

> Hi,
>=20
> I'm still getting the error associated with =
https://issues.apache.org/jira/browse/CASSANDRA-1700
> I have 7 suse nodes running Cassandra0.7 branch (latest as of the =
morning of Nov 9). I've loaded 10 rows with one column =
family(replication factor=3D4) and 100 super columns. Using the =
ColumnFamilyInputFormat with mapreduce (LocalJobRunner) to retrieve all =
the rows gives me the following exception:
>=20
> 10/11/10 10:33:15 WARN mapred.LocalJobRunner: job_local_0001
> java.lang.RuntimeException: org.apache.thrift.TApplicationException: =
Internal error processing get_range_slices
>        at =
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit=
(ColumnFamilyRecordReader.java:277)
>        at =
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNe=
xt(ColumnFamilyRecordReader.java:292)
>        at =
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNe=
xt(ColumnFamilyRecordReader.java:189)
>        at =
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterat=
or.java:136)
>        at =
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:1=
31)
>        at =
org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFa=
milyRecordReader.java:148)
>        at =
org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapT=
ask.java:423)
>        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:621)
>        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
>        at =
org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:177)
> Caused by: org.apache.thrift.TApplicationException: Internal error =
processing get_range_slices
>        at =
org.apache.thrift.TApplicationException.read(TApplicationException.java:10=
8)
>        at =
org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassand=
ra.java:724)
>        at =
org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.ja=
va:704)
>        at =
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit=
(ColumnFamilyRecordReader.java:255)
>        ... 11 more
>=20
> The server has the following exception:
> ERROR [pool-1-thread-11] 2010-11-10 10:35:58,839 Cassandra.java (line =
2876) Internal error processing get_range_slices
> java.lang.AssertionError: =
(150596448267070854052355226693835429313,188864318807883527921085450293725=
60769]
>        at =
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.=
java:1200)
>        at =
org.apache.cassandra.service.StorageProxy.getRangeSlice(StorageProxy.java:=
429)
>        at =
org.apache.cassandra.thrift.CassandraServer.get_range_slices(CassandraServ=
er.java:513)
>        at =
org.apache.cassandra.thrift.Cassandra$Processor$get_range_slices.process(C=
assandra.java:2868)
>        at =
org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:255=
5)
>        at =
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(Cust=
omTThreadPoolServer.java:167)
>        at =
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.=
java:886)
>        at =
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java=
:908)
>        at java.lang.Thread.run(Thread.java:619)
>=20
> Any help would be appreciated.
>=20
> Thanks.
>=20
> AD