incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeremy Hanna <jeremy.hanna1...@gmail.com>
Subject Re: word_count example fails in multi-node configuration
Date Mon, 29 Nov 2010 19:50:31 GMT
So final answer - known issue with RC1 - https://issues.apache.org/jira/browse/CASSANDRA-1781
- that should be fixed before 0.7.0 is completed.

On Nov 29, 2010, at 11:31 AM, Jeremy Hanna wrote:

> Roman:
> 
> I logged a jira ticket about this for further investigation, if you'd like to follow
that.
> 
> https://issues.apache.org/jira/browse/CASSANDRA-1787
> 
> 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
> 


Mime
View raw message