[FLINK-25415] implement retrial on connections to Cassandra container

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.5, 1.14.2, 1.15.0
• Fix Version/s: 1.13.6, 1.14.3, 1.15.0
• Component/s: Connectors / Cassandra, Tests
• Labels: pull-request-available
• Assignee: Etienne Chauchot
• Reporter: Etienne Chauchot
• Created: 22/Dec/21 09:47
• Updated: 29/Dec/21 17:09
• Resolved: 29/Dec/21 15:02

Description

NoHostAvailableException is raised by Cassandra client under load while connecting to a cluster. It happens no matter the Cassandra backend we use: I saw that using Achilles test backend, cassandra daemon and testContainers. So we should implement a retrial on the connection.

Issue Links

• Blocked: FLINK-23047 CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure
• is depended upon by: FLINK-25147 Migrate cassandra tests to test containers
• links to: GitHub Pull Request #18211