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();

Reply via email to