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?

Reply via email to