Hey,
I'm running a map/reduce job, reading from HDFS directory, and
reducing to Cassandra using the batch_mutate method.
The reducer builds the list of rowmutations for a single row, and
calls batch_mutate at the end. As I move to a larger dataset, i'm
seeing the following exception:
Caused by: TimedOutException()
at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:15361)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:796)
at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:772)
I changed the RpcTimeoutInMillis to 60 seconds with no changes. What
configuration changes should i make when doing intensive write
operations using batch mutate?
