[ 
https://issues.apache.org/jira/browse/FLINK-23058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367024#comment-17367024
 ] 

yandufeng commented on FLINK-23058:
-----------------------------------

it works, i forget to add elasticsearch's package

<dependency>
 <groupId>org.elasticsearch.client</groupId>
 <artifactId>elasticsearch-rest-high-level-client</artifactId>
 <version>6.8.16</version>
</dependency>

> flink-elasticsearch-6 not work
> ------------------------------
>
>                 Key: FLINK-23058
>                 URL: https://issues.apache.org/jira/browse/FLINK-23058
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / ElasticSearch
>    Affects Versions: 1.13.1
>            Reporter: yandufeng
>            Priority: Major
>              Labels: bug
>         Attachments: code.txt, 企业微信截图_16242678783453.png
>
>
> i have two questions.
> 1. when i add elasticserach host and port,i random write host, but not report 
> error. for example
> List<HttpHost> httpHosts = new ArrayList<>();
>  httpHosts.add(new HttpHost("sdfsdfsf", 9200, "http"));
> 2. when i write conrrect elasticsearch host and port, but no response, also 
> not create index in elasticsearch
>  
> !企业微信截图_16242678783453.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to