[ https://issues.apache.org/jira/browse/FLINK-8520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362144#comment-16362144 ]
Chesnay Schepler edited comment on FLINK-8520 at 2/13/18 11:09 AM: ------------------------------------------------------------------- There's a race condition between the callback decrementing the pending count and the sink checking&waiting on the count which can cause all cassandra sinks to deadlock during snapshotState() and close(). Bumping this to Blocker. was (Author: zentol): There's a race condition between the callback decrementing the pending count and the sink checking&waiting on the count which can cause the sink to deadlock during snapshotState() and close(). Bumping this to Blocker. > CassandraConnectorITCase.testCassandraTableSink unstable on Travis > ------------------------------------------------------------------ > > Key: FLINK-8520 > URL: https://issues.apache.org/jira/browse/FLINK-8520 > Project: Flink > Issue Type: Bug > Components: Cassandra Connector, Table API & SQL, Tests > Affects Versions: 1.5.0 > Reporter: Till Rohrmann > Assignee: Chesnay Schepler > Priority: Blocker > Labels: test-stability > Fix For: 1.5.0, 1.4.2 > > > The {{CassandraConnectorITCase.testCassandraTableSink}} fails on Travis with > a timeout. > > https://travis-ci.org/tillrohrmann/flink/jobs/333711342 -- This message was sent by Atlassian JIRA (v7.6.3#76005)