[
https://issues.apache.org/jira/browse/SPARK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Owen updated SPARK-5789:
-----------------------------
Assignee: Yin Huai
> Throw a better error message if JsonRDD.parseJson encounters unrecoverable
> parsing errors.
> ------------------------------------------------------------------------------------------
>
> Key: SPARK-5789
> URL: https://issues.apache.org/jira/browse/SPARK-5789
> Project: Spark
> Issue Type: Improvement
> Components: SQL
> Reporter: Yin Huai
> Assignee: Yin Huai
> Fix For: 1.3.0
>
>
> For example
> {code}
> sqlContext.jsonRDD(sc.parallelize(""""a":1}"""::Nil))
> {code}
> will throw
> {code}
> scala.MatchError: a (of class java.lang.String)
> at
> org.apache.spark.sql.json.JsonRDD$$anonfun$parseJson$1$$anonfun$apply$2.apply(JsonRDD.scala:302)
> at
> org.apache.spark.sql.json.JsonRDD$$anonfun$parseJson$1$$anonfun$apply$2.apply(JsonRDD.scala:300)
> at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371)
> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
> at org.apache.spark.rdd.RDD$$anonfun$19.apply(RDD.scala:879)
> at org.apache.spark.rdd.RDD$$anonfun$19.apply(RDD.scala:878)
> at
> org.apache.spark.SparkContext$$anonfun$30.apply(SparkContext.scala:1516)
> at
> org.apache.spark.SparkContext$$anonfun$30.apply(SparkContext.scala:1516)
> at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:61)
> at org.apache.spark.scheduler.Task.run(Task.scala:64)
> at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:197)
> 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)
> 15/02/12 15:08:55 INFO scheduler.TaskSetManager: Finished task 0.0 in stage
> 4.0 (TID 26) in 10 ms on localhost (7/8)
> 15/02/12 15:08:55 WARN scheduler.TaskSetManager: Lost task 7.0 in stage 4.0
> (TID 33, localhost): scala.MatchError: a (of class java.lang.String)
> at
> org.apache.spark.sql.json.JsonRDD$$anonfun$parseJson$1$$anonfun$apply$2.apply(JsonRDD.scala:302)
> at
> org.apache.spark.sql.json.JsonRDD$$anonfun$parseJson$1$$anonfun$apply$2.apply(JsonRDD.scala:300)
> at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371)
> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
> at org.apache.spark.rdd.RDD$$anonfun$19.apply(RDD.scala:879)
> at org.apache.spark.rdd.RDD$$anonfun$19.apply(RDD.scala:878)
> at
> org.apache.spark.SparkContext$$anonfun$30.apply(SparkContext.scala:1516)
> at
> org.apache.spark.SparkContext$$anonfun$30.apply(SparkContext.scala:1516)
> at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:61)
> at org.apache.spark.scheduler.Task.run(Task.scala:64)
> at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:197)
> 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)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
