spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pablo Federigi <>
Subject SaveToCassandra - how to handle failed inserts?
Date Fri, 07 Oct 2016 15:30:38 GMT

In the next example I'm using the method saveToCassandra from the
spark-cassandra connector

RDDJavaFunctions<Tuple2&lt;String, Integer>> dsJF1 =
      dsJF1.writerBuilder("test_keyspace", "test",
              CassandraJavaUtil.mapTupleToRow(String.class, Integer.class))

In the example above, we can suppose that result has 1000 records and just
one record fails when trying to write to cassandra (even after the Retry
Policy configuration).

I just want to know how to handle those failed records when the driver was
not able to write to cassandra (for example, due a timeout exception). It's
someway to log failed records?


View this message in context:
Sent from the Apache Spark User List mailing list archive at

To unsubscribe e-mail:

View raw message