写入es报错
来源:13-16 -统计分析结果入ES并通过Kibana图形化展示
爬行的蜗牛2019
2020-03-21
PK 哥, 写入es 报以下错误, 请问是什么原因呢,
20/03/21 17:46:15 ERROR rest.NetworkClient: Node [172.20.224.90:9200] failed (Connection refused (Connection refused)); no other nodes left - aborting…
Traceback (most recent call last):
File “/data/spark/script/spark032102.py”, line 38, in
result2014.write.format(“org.elasticsearch.spark.sql”).option(“es.nodes”, “172.20.224.90:9200”).mode(“overwrite”).save(“weaes/weather”)
File “/root/app/spark/spark-2.3.1-bin-2.6.0-cdh5.7.0/python/lib/pyspark.zip/pyspark/sql/readwriter.py”, line 705, in save
File “/root/app/spark/spark-2.3.1-bin-2.6.0-cdh5.7.0/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py”, line 1257, in call
File “/root/app/spark/spark-2.3.1-bin-2.6.0-cdh5.7.0/python/lib/pyspark.zip/pyspark/sql/utils.py”, line 63, in deco
File “/root/app/spark/spark-2.3.1-bin-2.6.0-cdh5.7.0/python/lib/py4j-0.10.7-src.zip/py4j/protocol.py”, line 328, in get_return_value
py4j.protocol.Py4JJavaError: An error occurred while calling o77.save.
: org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Cannot detect ES version - typically this happens if the network/Elasticsearch cluster is not accessible or when targeting a WAN/Cloud instance without the proper setting 'es.nodes.wan.only’
at org.elasticsearch.hadoop.rest.InitializationUtils.discoverEsVersion(InitializationUtils.java:327)
1回答
-
Michael_PK
2020-03-21
Cannot detect ES version - typically this happens if the network/Elasticsearch cluster is not accessible or when targeting a WAN/Cloud instance without the proper setting 'es.nodes.wan.only’你的es确定现在正常不
00
相似问题