Hi Jayant, afaik it is currently not possible to control how failures are handled in the Cassandra Sink. What would be the desired behaviour? The best thing is to open a JIRA issue to discuss potential improvements.
Cheers, Till On Thu, Aug 30, 2018 at 12:15 PM Jayant Ameta <wittyam...@gmail.com> wrote: > Hi, > During high volumes, cassandra sink fails with the following error: > com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra > timeout during write query at consistency SERIAL (2 replica were required > but only 1 acknowledged the write) > > Is there a way to configure the sink to ignore/handle this error? > > Jayant >
