Etienne Chauchot created FLINK-27457:
----------------------------------------
Summary: 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
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)
