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 3170f2a5c3b8e6b520dd4db55f8795a817266261 Author: Etienne Chauchot <[email protected]> AuthorDate: Tue May 2 16:52:52 2023 +0200 [FLINK-31927] Use default clusterBuilder reporting configuration in the tests --- .../apache/flink/connector/cassandra/CassandraTestEnvironment.java | 2 -- .../flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java | 5 +---- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java index 15b98d2..a0e649c 100644 --- a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java +++ b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java @@ -173,8 +173,6 @@ public class CassandraTestEnvironment implements TestResource { // default timeout x3 and higher than // request_timeout_in_ms at the cluster level .setReadTimeoutMillis(READ_TIMEOUT_MILLIS)) - .withoutJMXReporting() - .withoutMetrics() .build(); } }; diff --git a/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java b/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java index 560ea2a..7b81e57 100644 --- a/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java +++ b/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java @@ -62,10 +62,7 @@ class CassandraSinkBaseTest { new ClusterBuilder() { @Override protected Cluster buildCluster(Cluster.Builder builder) { - return builder.addContactPoint("127.0.0.1") - .withoutJMXReporting() - .withoutMetrics() - .build(); + return builder.addContactPoint("127.0.0.1").build(); } }, CassandraSinkBaseConfig.newBuilder().build(),
