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

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 33c550052c552dec086b11fbd5df27bd6feb1d19
Author: Chesnay Schepler <[email protected]>
AuthorDate: Fri Aug 5 09:09:08 2022 +0200

    [hotfix][tests] Remove unnecessary mock
---
 .../streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java
 
b/flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java
index 33675d1bc01..30417a52cc7 100644
--- 
a/flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java
+++ 
b/flink-connectors/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