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

SaurabhM (Saurabh Malviya) July 21, 2016, 7:28am 4

I dont see any specific built for scala 2.11

Getting exception
java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce$class

Es-hadoop scala 2.11 version issue

Topic		Replies	Views
Getting Error on sc.esRDD ES-Hadoop 5.2.2 Spark version 2.1.0 Elasticsearch es-hadoop	2	928	April 25, 2017
Exception while using elastic-hadoop library for Apache Spark from spark-shell Elasticsearch es-hadoop	3	768	July 21, 2017
Exception using elastic-hadoop library for Apache Spark Elasticsearch	1	507	July 19, 2017
java.lang.ClassNotFoundException: org.apache.spark.Partition$class Elasticsearch es-hadoop	1	1083	April 5, 2020
Issue Using the Connector from PySpark in 7.17.3 Elasticsearch es-hadoop	4	2903	June 4, 2022