https://issues.apache.org/jira/browse/FLINK-10310?focusedCommentId=16618447&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16618447
On Tue, Sep 11, 2018 at 10:15 AM Jayant Ameta <wittyam...@gmail.com> wrote: > 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 >>> >>