Hi,
I've a 4 node cluster of cassandra 0.8.7 (upgraded just recently from
0.7.8). Upgrade went smothly, no problem with the data.
Problem are my MapReduce tasks. The all report:
java.io.IOException: InvalidRequestException(why:Column timestamp is required)
at
org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:310)
Caused by: InvalidRequestException(why:Column timestamp is required)
at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:19479)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:1035)
at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:1009)
at
org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:302)
or
java.io.IOException: InvalidRequestException(why:Deletion timestamp is
not optional for non commutative column family PageData)
at
org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:310)
Caused by: InvalidRequestException(why:Deletion timestamp is not
optional for non commutative column family PageData)
at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:19479)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:1035)
at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:1009)
at
org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:302)
I only changed dependency in pom.xml on cassaandra-all 0.8.7 and
replaced .avro. with .thift. where needed. No compilation error. The
tasks run well with cassandra 0.7.x here on test and on the production
cluster.
I see there is a change in cassandra.thrift but it's I'm not using it
in the java application.
Can anybody help?
Regards,
Patrik
