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 apparc@gmail.com designates
 209.85.216.172 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=UwyXnBX6QJFBIMIBIAXw1E0Ka6OwazBeEAWUXJGHAsRKGu6cdY1SmrBNQlDHJcIj3i
         WU+sq4CMYDWTl3PgJJky2tGZq9kUrIJeEi2KuBgnbr0eZinxhg2prpLnUbSu474Hp7rL
         S4wczQ98JMt4JsOSRN0L2c/xqbtlMP0Dx4oX0=
MIME-Version: 1.0
In-Reply-To: <89AFE5E1-A0C3-4046-ADC5-9E0342A30870@gmail.com>
References: <AANLkTinfFn0Vz-G8mm1ixcyL2DvT3CTBDD7xZk4Rk7vm@mail.gmail.com>
	<89AFE5E1-A0C3-4046-ADC5-9E0342A30870@gmail.com>
Date: Tue, 30 Nov 2010 10:14:04 +0900
Message-ID: <AANLkTikhAGq6PJcrFbJbrko1h-OLcJysP7Hkq7Gvbm=L@mail.gmail.com>
Subject: Re: word_count example fails in multi-node configuration
From: RS <apparc@gmail.com>
To: user@cassandra.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

It occurs in 0.7 beta 3 and 0.7.0 rc 1.

Thank you, Jeremy. I will follow the ticket.

-Roman


On Tue, Nov 30, 2010 at 2:50 AM, Jeremy Hanna
<jeremy.hanna1234@gmail.com> wrote:
> Roman:
>
> I commented on the ticket - would you mind answering on there? =A0https:/=
/issues.apache.org/jira/browse/CASSANDRA-1787
>
> Tx,
>
> Jeremy
>
> On Nov 29, 2010, at 3:14 AM, RS wrote:
>
>> Hi guys,
>>
>> I am trying to run word_count example from contrib directory (0.7 beta
>> 3 and 0.7.0 rc 1).
>> It works fine in a single-node configuration, but fails with 2+ nodes.
>>
>> It fails in the assert statement, which caused problems before
>> (https://issues.apache.org/jira/browse/CASSANDRA-1700).
>>
>> Here's a simple ring I have and error messages.
>> ---
>> Address =A0 =A0 =A0 =A0 Status State =A0 Load =A0 =A0 =A0 =A0 =A0 =A0Own=
s =A0 =A0Token
>>
>> 143797990709940316224804537595633718982
>> 127.0.0.2 =A0 =A0 =A0 Up =A0 =A0 Normal =A040.2 KB =A0 =A0 =A0 =A0 51.38=
%
>> 61078635599166706937511052402724559481
>> 127.0.0.1 =A0 =A0 =A0 Up =A0 =A0 Normal =A036.01 KB =A0 =A0 =A0 =A048.62=
%
>> 143797990709940316224804537595633718982
>> ---
>> [SERVER SIDE]
>>
>> ERROR 17:39:57,098 Fatal exception in thread Thread[ReadStage:4,5,main]
>> java.lang.AssertionError:
>> (143797990709940316224804537595633718982,6107863559916670693751105240272=
4559481]
>> =A0 =A0 =A0 at org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(C=
olumnFamilyStore.java:1273)
>> =A0 =A0 =A0 at org.apache.cassandra.service.RangeSliceVerbHandler.doVerb=
(RangeSliceVerbHandler.java:48)
>> =A0 =A0 =A0 at org.apache.cassandra.net.MessageDeliveryTask.run(MessageD=
eliveryTask.java:62)
>> =A0 =A0 =A0 at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Th=
readPoolExecutor.java:886)
>> =A0 =A0 =A0 at java.util.concurrent.ThreadPoolExecutor$Worker.run(Thread=
PoolExecutor.java:908)
>> =A0 =A0 =A0 at java.lang.Thread.run(Thread.java:619)
>> ---
>> [CLIENT_SIDE]
>> java.lang.RuntimeException: org.apache.thrift.TApplicationException:
>> Internal error processing get_range_slices
>> =A0 =A0 =A0 at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowI=
terator.maybeInit(ColumnFamilyRecordReader.java:277)
>> =A0 =A0 =A0 at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowI=
terator.computeNext(ColumnFamilyRecordReader.java:292)
>> =A0 =A0 =A0 at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowI=
terator.computeNext(ColumnFamilyRecordReader.java:189)
>> =A0 =A0 =A0 at com.google.common.collect.AbstractIterator.tryToComputeNe=
xt(AbstractIterator.java:136)
>> =A0 =A0 =A0 at com.google.common.collect.AbstractIterator.hasNext(Abstra=
ctIterator.java:131)
>> =A0 =A0 =A0 at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.next=
KeyValue(ColumnFamilyRecordReader.java:148)
>> =A0 =A0 =A0 at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.=
nextKeyValue(MapTask.java:423)
>> =A0 =A0 =A0 at org.apache.hadoop.mapreduce.MapContext.nextKeyValue(MapCo=
ntext.java:67)
>> =A0 =A0 =A0 at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:143)
>> =A0 =A0 =A0 at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.jav=
a:621)
>> =A0 =A0 =A0 at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
>> =A0 =A0 =A0 at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobR=
unner.java:177)
>> Caused by: org.apache.thrift.TApplicationException: Internal error
>> processing get_range_slices
>> =A0 =A0 =A0 at org.apache.thrift.TApplicationException.read(TApplication=
Exception.java:108)
>> =A0 =A0 =A0 at org.apache.cassandra.thrift.Cassandra$Client.recv_get_ran=
ge_slices(Cassandra.java:724)
>> =A0 =A0 =A0 at org.apache.cassandra.thrift.Cassandra$Client.get_range_sl=
ices(Cassandra.java:704)
>> =A0 =A0 =A0 at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowI=
terator.maybeInit(ColumnFamilyRecordReader.java:255)
>> =A0 =A0 =A0 ... 11 more
>> ---
>>
>> Looks like tokens used in ColumnFamilySplits
>> (ColumnFamilyInputFormat.java) are on wrapping ranges (left_token >
>> right_token).
>> Any ideas how to fix this?
>>
>> --
>> Regards,
>> Roman
>
>