I am getting error while using es-hadoop with spark on scala11. It works with the spark-shell binaries I have with scala10 This line generates the error. val esRDD = sc.esRDD("realtimeanalytics/events") This works finaloutput.toJSON.saveJsonToEs("realtimeanalytics/events") Any inputs will be a…

Getting Error on sc.esRDD on Scala11 version of Spark

costin (Costin Leau) July 14, 2015, 7:42am 3

Scala 2.10 is not compatible with Scala 2.11 - make sure you use the proper es-spark artifact by specifying the proper Scala suffix

1 Like

Topic		Replies	Views
Es-hadoop scala 2.11 version issue Elasticsearch es-hadoop	2	1833	July 6, 2017
Getting Error on sc.esRDD ES-Hadoop 5.2.2 Spark version 2.1.0 Elasticsearch es-hadoop	2	941	April 25, 2017
Exception while using elastic-hadoop library for Apache Spark from spark-shell Elasticsearch es-hadoop	3	788	July 21, 2017
Exception using elastic-hadoop library for Apache Spark Elasticsearch	1	522	July 19, 2017
esRDD .count() is not working with my setup Elasticsearch es-hadoop	3	1080	March 13, 2017