[FLINK-31927] Cassandra source raises an exception on Flink 1.16.0 if the user enables the metrics in the cassandra driver

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.16.0, cassandra-3.1.0
• Fix Version/s: cassandra-3.1.0
• Component/s: Connectors / Cassandra
• Labels: pull-request-available
• Assignee: Etienne Chauchot
• Reporter: Etienne Chauchot
• Created: 24/Apr/23 18:26
• Updated: 05/May/23 09:23
• Resolved: 04/May/23 08:42

Description

CassandraSplitEnumerator#prepareSplits() raises java.lang.NoClassDefFoundError: com/codahale/metrics/Gauge when calling cluster.getMetadata() leading to NPE in CassandraSplitEnumerator#start() async callback.

Issue Links

• links to: GitHub Pull Request #13