cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dean Hiller <d...@alvazan.com>
Subject wordcount example exception that I think should not occur
Date Tue, 15 Nov 2011 02:01:30 GMT
There are 4 jobs submitted by the wordcount cassandra example and the first
one fails and the other 3 all pass and work with results.

The first job I noticed is looking for column name text0 due to i being 0
in the loop.  The exception is not going through the wordcount code at all
though, but this text0 column does not exist in the cassandra database(is
this an InputFormat bug in the cassandra code to wire in the map/reduce
stuff or is there a way to fix this???)

The exception...

2011-11-14 18:16:26,540 INFO org.apache.hadoop.mapred.TaskInProgress: Error
from attempt_201111141812_0002_m_000000_1:
java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
    at java.util.ArrayList.RangeCheck(ArrayList.java:547)
    at java.util.ArrayList.get(ArrayList.java:322)
    at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNext(ColumnFamilyRecordReader.java:300)
    at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNext(ColumnFamilyRecordReader.java:183)
    at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140)
    at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135)
    at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFamilyRecordReader.java:139)
    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.Child.main(Child.java:170)

thanks,
Dean

Mime
View raw message