flink-elasticsearch6-sink question

[闫杜峰 <du...@126.com>]

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


你好，我在使用flink-elasticsearch6-sink的功能，但是不能执行成功，存在以下两个问题。
1、当我随便写elasticsearch的hostname时，并不会有任何报错信息。例如
List<HttpHost> httpHosts = new ArrayList<>();
httpHosts.add(new HttpHost("sdfsdfsf", 9200, "http"));
填写的sdfsdfsf是不存在的。


2、当我使用docker启动一个elasticsearch时，程序并不会写入到elasticsearch中 ，但是也不报错。以下是代码附件。