# Getting error when invoking elasticSearch from spark

**URL:** <https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904>\
**Category:** Elasticsearch\
**Tags:** es-hadoop\
**Created:** [April 10, 2016, 4:56pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904 "2016-04-10T16:56:13Z")\
**Posts on this page:** 7\
**Page:** 1

<div class="post-metadata">

**Author:** ![ashish100](https://avatars.discourse-cdn.com/v4/letter/a/278dde/32.png) [@ashish100](https://discuss.elastic.co/u/ashish100)\
**Post date:** [April 10, 2016, 4:56pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/1 "2016-04-10T16:56:13Z")

</div>

I have a use case, where I need to read messages from kafka and for each message, extract data and invoke elasticsearch Index. The response will be further used to do further processing. I am getting below error when invoking JavaEsSpark.esJsonRDD

> java.lang.ClassCastException: org.elasticsearch.spark.rdd.EsPartition incompatible with org.apache.spark.rdd.ParallelCollectionPartition at org.apache.spark.rdd.ParallelCollectionRDD.compute(ParallelCollectionRDD.scala:102)  
> My code snippet is below

```
              public static void main(String[] args) {
                if (args.length < 4) {
                    System.err.println("Usage: JavaKafkaIntegration <zkQuorum> <group> <topics> <numThreads>");
                    System.exit(1);
                  }

                SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaIntegration").setMaster("local[2]").set("spark.driver.allowMultipleContexts", "true");
                //Setting when using JavaEsSpark.esJsonRDD
            sparkConf.set("es.nodes",<NODE URL>);
                sparkConf.set("es.nodes.wan.only","true");
                context = new JavaSparkContext(sparkConf);

                // Create the context with 2 seconds batch size
                JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(2000));

                int numThreads = Integer.parseInt(args[3]);
                Map<String, Integer> topicMap = new HashMap<>();
                String[] topics = args[2].split(",");
                for (String topic: topics) {
                  topicMap.put(topic, numThreads);
                }

                //Receive Message From kafka
                JavaPairReceiverInputDStream<String, String> messages =
                        KafkaUtils.createStream(jssc,args[0], args[1], topicMap);

                JavaDStream<String> jsons = messages
                        .map(new Function<Tuple2<String, String>, String>() {
                            /**
                             * 
                             */
                            private static final long serialVersionUID = 1L;

                            @Override
                            public String call(Tuple2<String, String> tuple2){

                                JavaRDD<String> esRDD = JavaEsSpark.esJsonRDD(context, <index>,<search string> ).values() ; 

                                 return null;

                            }

                        });             

                  jsons.print();
                  jssc.start();
                  jssc.awaitTermination();         

       }    

```

I am getting error when invoking JavaEsSpark.esJsonRDD. Is it correct way to do it? How do I successfully invoke ES from spark? I am running kafka and spark on windows and invoking external Elasticsearch index.  
I am using elasticsearch connector version 2.2.0 and spark version is spark 1.6.1. I have tried this with connector 2.3 as well.

---

<div class="post-metadata">

**Author:** ![costin](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/costin/32/44950_2.png) [@costin](https://discuss.elastic.co/u/costin)\
**Post date:** [April 11, 2016, 2:41pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/2 "2016-04-11T14:41:44Z")

</div>

It looks like an error in the data flow but I'm not sure what's the cause of the problem - indeed ES internal classes do not implement `ParallelCollectionPartition` since ES is not a parallel collection.  
I wonder if assuming the map needs to implement this is not a requirement from `JavaDStream` and a bug (since an RDD can be parallelized by Spark).

Can you post the whole stracktrace?

Thanks,

---

<div class="post-metadata">

**Author:** ![ashish100](https://avatars.discourse-cdn.com/v4/letter/a/278dde/32.png) [@ashish100](https://discuss.elastic.co/u/ashish100)\
**Post date:** [April 11, 2016, 3:37pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/3 "2016-04-11T15:37:10Z")

</div>

Below is the complete stacktrace. Let me know if anything else is required. sending multiple reply as there is a limit of 5000 chars.  
`  
Exception in thread "main" org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1.0 failed 1 times, most recent failure: Lost task 0.0 in stage 1.0 (TID 1, localhost): org.apache.spark.SparkException: Job aborted due to stage failure: Task 1 in stage 0.0 failed 1 times, most recent failure: Lost task 1.0 in stage 0.0 (TID 1, localhost): java.lang.ClassCastException: org.elasticsearch.spark.rdd.EsPartition incompatible with org.apache.spark.rdd.ParallelCollectionPartition  
at org.apache.spark.rdd.ParallelCollectionRDD.compute(ParallelCollectionRDD.scala:102)  
at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)  
at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)  
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)  
at org.apache.spark.scheduler.Task.run(Task.scala:89)  
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)  
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1157)  
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:627)  
at java.lang.Thread.run(Thread.java:798)

Driver stacktrace:  
at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)  
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)  
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)  
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)  
at scala.Option.foreach(Option.scala:236)  
at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:1640)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1599)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1588)  
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48)  
at java.lang.Thread.getStackTrace(Thread.java:1133)  
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:620)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1832)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1845)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1858)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1929)  
at org.apache.spark.rdd.RDD$$anonfun$collect$1.apply(RDD.scala:927)  
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150)  
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:111)  
at org.apache.spark.rdd.RDD.withScope(RDD.scala:316)  
at org.apache.spark.rdd.RDD.collect(RDD.scala:926)  
at org.apache.spark.api.java.JavaRDDLike$class.collect(JavaRDDLike.scala:339)  
at org.apache.spark.api.java.AbstractJavaRDDLike.collect(JavaRDDLike.scala:46)  
at test.KafkaIntegration2$2.call(KafkaIntegration2.java:185)  
at test.KafkaIntegration2$2.call(KafkaIntegration2.java:1)  
at org.apache.spark.api.java.JavaPairRDD$$anonfun$toScalaFunction$1.apply(JavaPairRDD.scala:1015)  
at scala.collection.Iterator$$anon$11.next(Iterator.scala:328)  
at scala.collection.Iterator$$anon$10.next(Iterator.scala:312)  
at scala.collection.Iterator$class.foreach(Iterator.scala:727)  
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)  
at scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48)  
at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:103)  
at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:47)  
at [scala.collection.TraversableOnce$class.to](http://scala.collection.TraversableOnce%24class.to)(TraversableOnce.scala:273)  
at [scala.collection.AbstractIterator.to](http://scala.collection.AbstractIterator.to)(Iterator.scala:1157)  
at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:265)  
at scala.collection.AbstractIterator.toBuffer(Iterator.scala:1157)  
at scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:252)  
at scala.collection.AbstractIterator.toArray(Iterator.scala:1157)  
at org.apache.spark.rdd.RDD$$anonfun$take$1$$anonfun$28.apply(RDD.scala:1328)  
at org.apache.spark.rdd.RDD$$anonfun$take$1$$anonfun$28.apply(RDD.scala:1328)  
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)  
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)  
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)  
`

---

<div class="post-metadata">

**Author:** ![ashish100](https://avatars.discourse-cdn.com/v4/letter/a/278dde/32.png) [@ashish100](https://discuss.elastic.co/u/ashish100)\
**Post date:** [April 11, 2016, 3:38pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/4 "2016-04-11T15:38:26Z")

</div>

` at org.apache.spark.scheduler.Task.run(Task.scala:89)  
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)  
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1157)  
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:627)  
at java.lang.Thread.run(Thread.java:798)  
Caused by: java.lang.ClassCastException: org.elasticsearch.spark.rdd.EsPartition incompatible with org.apache.spark.rdd.ParallelCollectionPartition  
at org.apache.spark.rdd.ParallelCollectionRDD.compute(ParallelCollectionRDD.scala:102)  
at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)  
at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)  
... 6 more

Driver stacktrace:  
at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)  
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)  
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)  
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)  
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)  
at scala.Option.foreach(Option.scala:236)  
at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:1640)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1599)  
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1588)  
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48)  
at java.lang.Thread.getStackTrace(Thread.java:1133)  
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:620)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1832)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1845)  
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1858)  
at org.apache.spark.rdd.RDD$$anonfun$take$1.apply(RDD.scala:1328)  
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150)  
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:111)  
at org.apache.spark.rdd.RDD.withScope(RDD.scala:316)  
at org.apache.spark.rdd.RDD.take(RDD.scala:1302)  
at org.apache.spark.streaming.dstream.DStream$$anonfun$print$2$$anonfun$foreachFunc$5$1.apply(DStream.scala:768)  
at org.apache.spark.streaming.dstream.DStream$$anonfun$print$2$$anonfun$foreachFunc$5$1.apply(DStream.scala:767)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:50)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:50)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:50)  
at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:426)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:49)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:49)  
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:49)  
at scala.util.Try$.apply(Try.scala:161)  
at org.apache.spark.streaming.scheduler.Job.run(Job.scala:39)  
at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply$mcV$sp(JobScheduler.scala:224)  
at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply(JobScheduler.scala:224)  
at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply(JobScheduler.scala:224)  
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57)  
at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler.run(JobScheduler.scala:223)  
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1157)  
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:627)  
at java.lang.Thread.run(Thread.java:798)  
Caused by: org.apache.spark.SparkException: Job aborted due to stage failure: Task 1 in stage 0.0 failed 1 times, most recent failure: Lost task 1.0 in stage 0.0 (TID 1, localhost): java.lang.ClassCastException: org.elasticsearch.spark.rdd.EsPartition incompatible with org.apache.spark.rdd.ParallelCollectionPartition  
at org.apache.spark.rdd.ParallelCollectionRDD.compute(ParallelCollectionRDD.scala:102)  
at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)  
`

---

<div class="post-metadata">

**Author:** ![ashish100](https://avatars.discourse-cdn.com/v4/letter/a/278dde/32.png) [@ashish100](https://discuss.elastic.co/u/ashish100)\
**Post date:** [April 11, 2016, 3:46pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/5 "2016-04-11T15:46:24Z")

</div>

```
at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1157)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:627)
	at java.lang.Thread.run(Thread.java:798)

Driver stacktrace:
	at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)
	at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)
	at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
	at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)
	at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)
	at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)
	at scala.Option.foreach(Option.scala:236)
	at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)
	at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:1640)
	at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1599)
	at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1588)
	at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48)
	at java.lang.Thread.getStackTrace(Thread.java:1133)
	at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:620)
	at org.apache.spark.SparkContext.runJob(SparkContext.scala:1832)
	at org.apache.spark.SparkContext.runJob(SparkContext.scala:1845)
	at org.apache.spark.SparkContext.runJob(SparkContext.scala:1858)
	at org.apache.spark.SparkContext.runJob(SparkContext.scala:1929)
	at org.apache.spark.rdd.RDD$$anonfun$collect$1.apply(RDD.scala:927)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:111)
	at org.apache.spark.rdd.RDD.withScope(RDD.scala:316)
	at org.apache.spark.rdd.RDD.collect(RDD.scala:926)
	at org.apache.spark.api.java.JavaRDDLike$class.collect(JavaRDDLike.scala:339)
	at org.apache.spark.api.java.AbstractJavaRDDLike.collect(JavaRDDLike.scala:46)
	at test.KafkaIntegration2$2.call(KafkaIntegration2.java:185)
	at test.KafkaIntegration2$2.call(KafkaIntegration2.java:1)
	at org.apache.spark.api.java.JavaPairRDD$$anonfun$toScalaFunction$1.apply(JavaPairRDD.scala:1015)
	at scala.collection.Iterator$$anon$11.next(Iterator.scala:328)
	at scala.collection.Iterator$$anon$10.next(Iterator.scala:312)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48)
	at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:103)
	at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:47)
	at scala.collection.TraversableOnce$class.to(TraversableOnce.scala:273)
	at scala.collection.AbstractIterator.to(Iterator.scala:1157)
	at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:265)
	at scala.collection.AbstractIterator.toBuffer(Iterator.scala:1157)
	at scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:252)
	at scala.collection.AbstractIterator.toArray(Iterator.scala:1157)
	at org.apache.spark.rdd.RDD$$anonfun$take$1$$anonfun$28.apply(RDD.scala:1328)
	at org.apache.spark.rdd.RDD$$anonfun$take$1$$anonfun$28.apply(RDD.scala:1328)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	... 3 more
Caused by: java.lang.ClassCastException: org.elasticsearch.spark.rdd.EsPartition incompatible with org.apache.spark.rdd.ParallelCollectionPartition
	at org.apache.spark.rdd.ParallelCollectionRDD.compute(ParallelCollectionRDD.scala:102)
	at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)
	at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)
	... 6 more
-------------------------------------------
```

---

<div class="post-metadata">

**Author:** ![costin](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/costin/32/44950_2.png) [@costin](https://discuss.elastic.co/u/costin)\
**Post date:** [April 11, 2016, 3:48pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/6 "2016-04-11T15:48:03Z")

</div>

PS formatting and gist/pastebin always help 😉

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 1:25pm UTC](https://discuss.elastic.co/t/getting-error-when-invoking-elasticsearch-from-spark/46904/7 "2017-07-06T13:25:14Z")

</div>