写入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确定现在正常不

0
0

Python3实战Spark大数据分析及调度

使用Python3对Spark应用程序进行开发调优,掌握Azkaban任务调度

1046 学习 · 434 问题

查看课程