[FLINK-27457] CassandraOutputFormats should support flush

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.16.0
• Component/s: Connectors / Cassandra
• Labels: pull-request-available
• Assignee: Etienne Chauchot
• Reporter: Etienne Chauchot
• Created: 29/Apr/22 15:08
• Updated: 08/Jun/22 14:14
• Resolved: 08/Jun/22 08:12

Description

When migrating to Cassandra 4.x in this PR 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.

Issue Links

• relates to: FLINK-27884 Introduce OutputFormatBase to provide flushing/maxConcurrentRequests functionality
• links to: GitHub Pull Request #19680