# Elasticsearch-spark connector failing to save data with an Illegal Argument Exception : "No class name given" **URL:** \ **Category:** Elasticsearch\ **Tags:** es-hadoop\ **Created:** [August 26, 2016, 9:49am UTC](https://discuss.elastic.co/t/elasticsearch-spark-connector-failing-to-save-data-with-an-illegal-argument-exception-no-class-name-given/59024 "2016-08-26T09:49:18Z")\ **Posts on this page:** 4\ **Page:** 1
**Author:** ![eliasah](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/eliasah/32/34741_2.png) [@eliasah](https://discuss.elastic.co/u/eliasah)\ **Post date:** [August 26, 2016, 9:49am UTC](https://discuss.elastic.co/t/elasticsearch-spark-connector-failing-to-save-data-with-an-illegal-argument-exception-no-class-name-given/59024/1 "2016-08-26T09:49:18Z")
``` Exception in thread "main" org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: No class name given at org.elasticsearch.hadoop.util.Assert.hasText(Assert.java:30) at org.elasticsearch.hadoop.util.ObjectUtils.instantiate(ObjectUtils.java:32) at org.elasticsearch.hadoop.util.ObjectUtils.instantiate(ObjectUtils.java:52) at org.elasticsearch.hadoop.util.ObjectUtils.instantiate(ObjectUtils.java:48) at org.elasticsearch.hadoop.serialization.bulk.AbstractBulkFactory.initExtractorsFromSettings(AbstractBulkFactory.java:198) at org.elasticsearch.hadoop.serialization.bulk.AbstractBulkFactory.(AbstractBulkFactory.java:174) at org.elasticsearch.hadoop.serialization.bulk.IndexBulkFactory.(IndexBulkFactory.java:27) at org.elasticsearch.hadoop.serialization.bulk.BulkCommands.create(BulkCommands.java:39) at org.elasticsearch.hadoop.rest.RestRepository.lazyInitWriting(RestRepository.java:130) at org.elasticsearch.hadoop.rest.RestRepository.writeProcessedToIndex(RestRepository.java:174) at org.elasticsearch.hadoop.rest.RestRepository.delete(RestRepository.java:549) at org.elasticsearch.spark.sql.ElasticsearchRelation.insert(DefaultSource.scala:481) at org.elasticsearch.spark.sql.DefaultSource.createRelation(DefaultSource.scala:76) at org.apache.spark.sql.execution.datasources.ResolvedDataSource$.apply(ResolvedDataSource.scala:222) at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:148) at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:139) ... ``` I'm not sure what does that error message means. I have followed the error thread which laid me to the following line ``` Assert.hasText(className, "No class name given"); // at org.elasticsearch.hadoop.util.ObjectUtils.instantiate(ObjectUtils.java:32) ``` Information about the data : ``` scala> data // res0: org.apache.spark.sql.DataFrame = [doc_id: bigint, eventDate: timestamp, marketObjectId: bigint, eventType: string, merchantId: bigint, userId: bigint] scala> data.printSchema // root // |-- doc_id: long (nullable = false) // |-- eventDate: timestamp (nullable = true) // |-- marketObjectId: long (nullable = true) // |-- eventType: string (nullable = true) // |-- merchantId: long (nullable = true) // |-- userId: long (nullable = true) ``` code snippet : ``` val config: scala.collection.mutable.Map[String, String] = scala.collection.mutable.Map( "pushdown" -> "true", "es.nodes" -> "localhost:9200", // params.esHost "es.mapping.id" -> "doc_id" ) data.write.format("org.elasticsearch.spark.sql") .mode(SaveMode.Overwrite) .options(config) .save("clicks/event") ``` I'm using **Spark 1.6.2** with **elasticsearch-spark\_2.10 v. 5.0.0.BUILD-SNAPSHOT** in _standalone mode_. ``` { "name" : "Callisto", "cluster_name" : "elasticsearch", "version" : { "number" : "5.0.0-alpha4", "build_hash" : "3f5b994", "build_date" : "2016-06-27T16:23:46.861Z", "build_snapshot" : false, "lucene_version" : "6.1.0" }, "tagline" : "You Know, for Search" } ``` The project is assembled with maven (mvn assembly:assembly) to create an uber-jar so all the dependencies are available. **EDIT :** Reading data from elasticsearch works perfectly : ``` sqlContext.read.format("org.elasticsearch.spark.sql") .options(config).load("clicks/event") ``` _How can I fix this ?_ Any help would be appreciated. Thanks ! ---
**Author:** ![james.baiera](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/james.baiera/32/10209_2.png) [@james.baiera](https://discuss.elastic.co/u/james.baiera)\ **Post date:** [August 26, 2016, 10:08pm UTC](https://discuss.elastic.co/t/elasticsearch-spark-connector-failing-to-save-data-with-an-illegal-argument-exception-no-class-name-given/59024/2 "2016-08-26T22:08:18Z")
Hi @eliasah, I took a quick look and was able to reproduce this locally. Could you open an issue on [https://github.com/elastic/elasticsearch-hadoop/issues/new](https://github.com/elastic/elasticsearch-hadoop/issues/new) for this? This is definitely a bug. ---
**Author:** ![eliasah](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/eliasah/32/34741_2.png) [@eliasah](https://discuss.elastic.co/u/eliasah)\ **Post date:** [August 29, 2016, 6:51am UTC](https://discuss.elastic.co/t/elasticsearch-spark-connector-failing-to-save-data-with-an-illegal-argument-exception-no-class-name-given/59024/3 "2016-08-29T06:51:01Z")
Thanks @james.baiera ! I have submitted an issue [https://github.com/elastic/elasticsearch-hadoop/issues/837](https://github.com/elastic/elasticsearch-hadoop/issues/837) with some additional information. And like I've said in the issue, I have some doubts concerning the `SaveMode.Overwrite` option that might be causing troubles as it's not recognized by the connector and might be the reason of the `EsHadoopIllegalArgumentException: No class name given`. ---
**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:23pm UTC](https://discuss.elastic.co/t/elasticsearch-spark-connector-failing-to-save-data-with-an-illegal-argument-exception-no-class-name-given/59024/4 "2017-07-06T13:23:32Z")