eStreams.java:733)
>>>> at
>>>>
>>>> org.apache.spark.sql.execution.UnsafeRowSerializerInstance$$anon$3$$anon$1.next(UnsafeRowSerializer.scala:119)
>>>>
>>> org.apache.spark.sql.execution.UnsafeExternalRowSorter.sort(UnsafeExternalRowSorter.java:168)
>>> at
>>> org.apache.spark.sql.execution.Sort$$anonfun$1.apply(Sort.scala:90)
>>> at
>>> org.apache.spark.sql.execution.Sort$$anonfun$1.appl
$anon$12.hasNext(Iterator.scala:396)
> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:369)
> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:369)
> at
>
> org.apache.spark.shuffle.so
)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/DataFrame-job-fails-on-parsing-error-help-tp26724.html
Sent from the Apache Spark User List mailing list archive
