This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
commit 132f0e347a384b771347e320cd3587b6d42605b7 Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Mon Sep 12 15:47:59 2022 +0200 [hotfix][tests] Remove unnecessary mock --- .../streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java b/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java index 33675d1..30417a5 100644 --- a/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java +++ b/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java @@ -425,7 +425,7 @@ public class ElasticsearchSinkBaseTest { new DummyElasticsearchSink<>( new HashMap<>(), sinkFunction, new DummyRetryFailureHandler()); - sink.open(mock(Configuration.class)); + sink.open(new Configuration()); sink.close(); assertThat(sinkFunction.openCalled).isTrue();