Answering myself: it seems we can't have any non type 1 UUIDs in column names. I used the UTF8 comparator and saved my UUIDs as strings, it worked.
2012/10/29 Marcelo Elias Del Valle <mvall...@gmail.com> > Hello, > > I am using ColumnFamilyInputFormat the same way it's described in this > example: > https://github.com/apache/cassandra/blob/trunk/examples/hadoop_word_count/src/WordCount.java#L215 > > I have been able to successfully process data in cassandra by using > hadoop. However, as this solution doesn't allow me to filter which data in > cassandra I want to filter, I decided to create a query column family to > list data I want to process in hadoop. This column family is as follows: > > row key: YYYYMM > column name: UUID - user ID > column value: timestamp - last processed date > > The problem is, when I run hadoop, I get the exception bellow. Is > there any limitation in having UUIDs as column names? I am generating my > user IDs with java.util.UUID.randomUUID() for now. I could change the > method later, but only type 1 UUIDs are 16 bits longer, isn't it? > > > java.lang.RuntimeException: InvalidRequestException(why:UUIDs must be > exactly 16 bytes) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.maybeInit(ColumnFamilyRecordReader.java:391) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.computeNext(ColumnFamilyRecordReader.java:397) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.computeNext(ColumnFamilyRecordReader.java:323) > at > com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) > at > com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFamilyRecordReader.java:188) > at > org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:532) > 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:764) > at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370) > at > org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) > Caused by: InvalidRequestException(why:UUIDs must be exactly 16 bytes) > at > org.apache.cassandra.thrift.Cassandra$get_range_slices_result.read(Cassandra.java:12254) > at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) > at > org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:683) > at > org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java:667) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.maybeInit(ColumnFamilyRecordReader.java:356) > ... 11 more > > Best regards, > -- > Marcelo Elias Del Valle > http://mvalle.com - @mvallebr > -- Marcelo Elias Del Valle http://mvalle.com - @mvallebr
