[FLINK-26793] Flink Cassandra connector performance issue

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.4
• Fix Version/s: 1.16.0
• Component/s: Connectors / Cassandra
• Labels: documentation pull-request-available
• Assignee: Etienne Chauchot
• Reporter: Jay Ghiya
• Created: 22/Mar/22 06:32
• Updated: 05/Jul/22 12:22
• Resolved: 05/Jul/22 11:05

Description

A warning is observed during long runs of flink job stating “Insertions into scylla might be suffering. Expect performance problems unless this is resolved.”
Upon initial analysis - “flink cassandra connector is not keeping instance of mapping manager that is used to convert a pojo to cassandra row. Ideally the mapping manager should have the same life time as cluster and session objects which are also created once when the driver is initialized”
Reference: https://stackoverflow.com/questions/59203418/cassandra-java-driver-warning

Issue Links

• links to: GitHub Pull Request #19944