Well, by edting
src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
in version 1.0.2 cassandra src just before the
totalRead++;
KeySlice ks = rows.get(i++);
SortedMap map = new TreeMap(comparator);
I added the code
if(i >= rows.size
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 thi