You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/08/06 20:42:31 UTC
[flink] 01/02: [hotfix][tests] Remove unnecessary mock
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 <ch...@apache.org>
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();