sqlContext.read.format("es").load() set es.nodes

Elastic Stack Elasticsearch
1

my elasticsearch in other nodes, but sqlContext cat't find this node
org.elasticsearch.hadoop.rest.EsHadoopNoNodesLeftException: Connection error (check network and/or proxy settings)- all nodes failed; tried [[localhost:9200]]

conf = {"es.resource" : "xxx/xxx", "es.nodes": "10.10.1.111:9200"}
sc = SparkContext("local[*]", "es_spark",conf=conf)
sqlContext = SQLContext(sc)
df = sqlContext.read.format("org.elasticsearch.spark.sql").load("xxx/xxx")

2

@whybangbang Could you include trace level logging for your job driver? That should help shed some light on the issue you're experiencing.

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.