Skip to content

Commit 646976b

Browse files
committed
Fix JSON RDD Conversion too
1 parent 59065bc commit 646976b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/json/JsonRDD.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,8 @@
1818
package org.apache.spark.sql.json
1919

2020
import scala.collection.Map
21-
import scala.collection.convert.Wrappers.{JMapWrapper, JListWrapper}
21+
import scala.collection.JavaConversions._
22+
import scala.collection.convert.Wrappers.JMapWrapper
2223
import scala.math.BigDecimal
2324

2425
import com.fasterxml.jackson.databind.ObjectMapper
@@ -253,7 +254,7 @@ private[sql] object JsonRDD extends Logging {
253254
// This issue is documented at https://issues.scala-lang.org/browse/SI-7005
254255
JMapWrapper(map).mapValues(scalafy).map(identity)
255256
case list: java.util.List[_] =>
256-
JListWrapper(list).map(scalafy)
257+
(list: Seq[_]).map(scalafy)
257258
case atom => atom
258259
}
259260

0 commit comments

Comments
 (0)