EsHadoopIllegalStateException.txt

15/11/11 15:35:16 INFO Version: Elasticsearch Hadoop v2.1.2 [4decc4332a]
15/11/11 15:35:17 INFO EsRDDWriter: Writing to [test1447284876390/test1447284876390]
15/11/11 15:35:17 INFO ScalaEsRowRDD: Reading from [test1447284876390/test1447284876390]
15/11/11 15:35:17 INFO ScalaEsRowRDD: Discovered mapping {test1447284876390=[mappings=[test1447284876390=[rect=GEO_SHAPE]]]} for [test1447284876390/test1447284876390]
15/11/11 15:35:17 ERROR Executor: Exception in task 2.0 in stage 2.0 (TID 4)
org.elasticsearch.hadoop.EsHadoopIllegalStateException: Field 'rect' not found; typically this occurs with arrays which are not mapped as single value
	at org.elasticsearch.spark.sql.RowValueReader$class.rowColumns(RowValueReader.scala:33)
	at org.elasticsearch.spark.sql.ScalaRowValueReader.rowColumns(ScalaEsRowValueReader.scala:13)
	at org.elasticsearch.spark.sql.ScalaRowValueReader.createMap(ScalaEsRowValueReader.scala:49)
	at org.elasticsearch.hadoop.serialization.ScrollReader.map(ScrollReader.java:644)
	at org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:587)
	at org.elasticsearch.hadoop.serialization.ScrollReader.map(ScrollReader.java:660)
	at org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:587)
	at org.elasticsearch.hadoop.serialization.ScrollReader.readHitAsMap(ScrollReader.java:382)
	at org.elasticsearch.hadoop.serialization.ScrollReader.readHit(ScrollReader.java:317)
	at org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:212)
	at org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:186)
	at org.elasticsearch.hadoop.rest.RestRepository.scroll(RestRepository.java:408)
	at org.elasticsearch.hadoop.rest.ScrollQuery.hasNext(ScrollQuery.java:86)
	at org.elasticsearch.spark.rdd.AbstractEsRDDIterator.hasNext(AbstractEsRDDIterator.scala:43)
	at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
	at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
	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$collect$1$$anonfun$12.apply(RDD.scala:885)
	at org.apache.spark.rdd.RDD$$anonfun$collect$1$$anonfun$12.apply(RDD.scala:885)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1767)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1767)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:63)
	at org.apache.spark.scheduler.Task.run(Task.scala:70)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:213)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)