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?