Hi Till, I've opened a JIRA issue: https://issues.apache.org/jira/browse/FLINK-10310. Can we discuss it?
Jayant Ameta On Thu, Aug 30, 2018 at 4:35 PM Till Rohrmann <trohrm...@apache.org> wrote: > 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 >> >
