You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/09/22 09:04:27 UTC
[flink] branch release-1.11 updated: [hotfix] Fix typo in ES6 test
sanity check
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new b363e88 [hotfix] Fix typo in ES6 test sanity check
b363e88 is described below
commit b363e8800cd15a1bcc59bb08d96c19be8b437516
Author: Aljoscha Krettek <al...@apache.org>
AuthorDate: Tue Sep 22 11:03:33 2020 +0200
[hotfix] Fix typo in ES6 test sanity check
---
.../streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
index 3251a79..2945f8a 100644
--- a/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
+++ b/flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
@@ -41,7 +41,7 @@ public class ElasticsearchSinkITCase extends ElasticsearchSinkTestBase<RestHighL
@Before
public void ensureClusterIsUp() throws IOException {
- RestClientBuilder builder = RestClient.builder(HttpHost.create("http://127.0.0.2:9200"));
+ RestClientBuilder builder = RestClient.builder(HttpHost.create("http://127.0.0.1:9200"));
RestHighLevelClient client = new RestHighLevelClient(builder);
if (!client.ping()) {
throw new RuntimeException("Cannot ping cluster!");