Apache Flink 1.2 – 客户端未连接到任何Elasticsearch节点

我是ElasticSearch的新手,我select它是为了使用Apache Flink作为接收器执行数据stream处理。 因为Flink 1.2只有ES的2.x版本才有连接器,所以我使用了一个合适的docker镜像(elasticsearch:2.4.4-alpine)。 我遵循文档上的例子 ,使用“elasticsearch”作为cluster.name (默认值), 127.0.0.1:9200作为节点地址。 我用docker run -p 9200:9200 "http.host=0.0.0.0" elasticsearch:2.4.4-alpine启动我的docker run -p 9200:9200 "http.host=0.0.0.0" elasticsearch:2.4.4-alpine 。 有时节点收到一些东西,但是会导致IllegalArgumentException:空文本。

Interesting Posts