You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/06 11:34:00 UTC

[jira] [Assigned] (FLINK-27457) CassandraOutputFormats should support flush

     [ https://issues.apache.org/jira/browse/FLINK-27457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler reassigned FLINK-27457:
----------------------------------------

    Assignee: Etienne Chauchot

> CassandraOutputFormats should support flush
> -------------------------------------------
>
>                 Key: FLINK-27457
>                 URL: https://issues.apache.org/jira/browse/FLINK-27457
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Cassandra
>            Reporter: Etienne Chauchot
>            Assignee: Etienne Chauchot
>            Priority: Major
>
> When migrating to Cassandra 4.x in [this PR|https://github.com/apache/flink/pull/19586] a race condition in the tests between the asynchronous writes and the junit assertions was uncovered. So it was decided to introduce the flush mechanism to asynchronous writes in the Cassandra output formats similarly to what was done in Cassandra sinks.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)