Я пытаюсь загрузить данные из ноутбука pyspark jupyteer в эластичный поиск.это дает мне эту ошибку:
Произошла ошибка при вызове z: org.apache.spark.api.python.PythonRDD.saveAsNewAPIHadoopFile.: org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Невозможно определить версию ES - обычно это происходит, если кластер network / Elasticsearch недоступен или когда нацеливается на экземпляр WAN / Cloud без правильного параметра es.nodes.wan.only '
мой конф:
x.saveAsNewAPIHadoopFile(
path='_',
outputFormatClass="org.elasticsearch.hadoop.mr.EsOutputFormat", # get it from pyspark jar file
valueClass="org.elasticsearch.hadoop.mr.LinkedMapWritable",
conf=conf
)