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

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": ""}
sc = SparkContext("local[*]", "es_spark",conf=conf)
sqlContext = SQLContext(sc)
df = sqlContext.read.format("org.elasticsearch.spark.sql").load("xxx/xxx")

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

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