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