# 情景 当前使用flink1.13写入es5.1.1,在使用idea启动项目过程中,报错如下所示: Elasticsearch client is not connected to any Elasticsearch nodes! # 问题原因 这个主要是因为代码中cluster.name写错了 # 获取cluster.name
# 注意 主要代码如上所示,需要注意的是, 1. cluster.name 需要先查询之后再写 2. es5.x之前端口是9300,es6.x之后端口是9200 这个在官网有很明确的代码示例 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/elasticsearch/



