This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a commit to branch v3.1
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git
commit 92ee0991a268e11c7db25c1aa040bbdebfc697f7
Author: Etienne Chauchot <echauc...@apache.org>
AuthorDate: Tue May 2 16:29:45 2023 +0200
[FLINK-31927] 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());
}
/**
