[prev in list] [next in list] [prev in thread] [next in thread]
List: cassandra-user
Subject: Re: word_count example fails in multi-node configuration
From: RS <apparc () gmail ! com>
Date: 2010-11-30 1:14:04
Message-ID: AANLkTikhAGq6PJcrFbJbrko1h-OLcJysP7Hkq7Gvbm=L () mail ! gmail ! com
[Download RAW message or body]
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? \
> https://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 Status State Load Owns Token
> >
> > 143797990709940316224804537595633718982
> > 127.0.0.2 Up Normal 40.2 KB 51.38%
> > 61078635599166706937511052402724559481
> > 127.0.0.1 Up Normal 36.01 KB 48.62%
> > 143797990709940316224804537595633718982
> > ---
> > [SERVER SIDE]
> >
> > ERROR 17:39:57,098 Fatal exception in thread Thread[ReadStage:4,5,main]
> > java.lang.AssertionError:
> > (143797990709940316224804537595633718982,61078635599166706937511052402724559481]
> > at org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:1273)
> > at org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:48)
> > at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:62)
> > 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)
> > ---
> > [CLIENT_SIDE]
> > 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.computeNext(ColumnFamilyRecordReader.java:292)
> > at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNext(ColumnFamilyRecordReader.java:189)
> > at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:136)
> > at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:131)
> > at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFamilyRecordReader.java:148)
> > at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.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:108)
> > at org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:724)
> > at org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java:704)
> > at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit(ColumnFamilyRecordReader.java:255)
> >
> > ... 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
>
>
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic