It was a typo in my example code in this email. I logged the list to
make sure that everything was correct before trigger the write.
Will try to enable debug on both cassandra and hadoop next.
Thanks,
Trung.
On Tue, Jan 18, 2011 at 1:21 AM, Aaron Morton wrote:
> May just be your example code, b
May just be your example code, but you are repeating colName2 . Can you log the
mutation list before you write it and confirm you have unique column names?
Can you turn up the logging to DEBUG for the hadoop job and the Cassandra
cluster to see what's happening?
Aaron
On 18/01/2011, at 9:40 PM
Hi,
I'm working on ColumnFamilyOutputFormat and for some reasons my reduce
class does not write all columns to cassandra. I tried to modify
mapreduce.output.columnfamilyoutputformat.batch.threshold with some
different values (1, 8, .. etc) but no thing changes.
What i'm having in my reduce class
