Re: Cassandra Hadoop integration issue using CFIF

2012-08-29 Thread Ben Frank
This line always returns "0" because the key ByteBuffer has already been read from. startToken = partitioner.getTokenFactory().toString(partitioner.getToken(Iterables.getLast(rows).key)); I was able to get it to work by using .mark() and .reset() on the buffer. I'll log a bug, but confused as to

Cassandra Hadoop integration issue using CFIF

2012-08-29 Thread Ben Frank
Hey all, I'm having an issue using ColumnFamilyInputFormat in an hadoop job. The mappers spin out of control and just keep reading records over and over, never getting to the end. I have CF with wide rows (although none is past about 5 at the columns at the moment), I've tried setting wide rows