[flink-connector-cassandra] 01/02: [FLINK-31749] Disable cassandra driver metrics as they are not integrated with Flink metrics

[ec...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git

commit 275804c445e9c47ab408a108c6583118ea13ec69
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Tue May 2 16:29:45 2023 +0200

    [FLINK-31749] Disable cassandra driver metrics as they are not integrated with Flink metrics
---
 .../apache/flink/streaming/connectors/cassandra/ClusterBuilder.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java b/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java
index fb537bc..9a98892 100644
--- a/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java
+++ b/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java
@@ -24,12 +24,13 @@ import java.io.Serializable;
 
 /**
  * This class is used to configure a {@link com.datastax.driver.core.Cluster} after deployment. The
- * cluster represents the connection that will be established to Cassandra.
+ * cluster represents the connection that will be established to Cassandra. Cassandra driver metrics
+ * are not integrated with Flink metrics, so they are disabled.
  */
 public abstract class ClusterBuilder implements Serializable {
 
     public Cluster getCluster() {
-        return buildCluster(Cluster.builder());
+        return buildCluster(Cluster.builder().withoutMetrics());
     }
 
     /**