diff options
| author | Josh Rosen <joshrosen@apache.org> | 2014-01-23 13:05:59 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-01-23 13:05:59 -0800 |
| commit | 0035dbbc8125af94ae27cb6f10e87aa6f5a078b1 (patch) | |
| tree | c0c87e7f66a1c09b6ac62d16ae862ae798b65c0c /core | |
| parent | a2b47dae66a437f02bc053e9bde5c1472cff0fc6 (diff) | |
| download | spark-0035dbbc8125af94ae27cb6f10e87aa6f5a078b1.tar.gz spark-0035dbbc8125af94ae27cb6f10e87aa6f5a078b1.tar.bz2 spark-0035dbbc8125af94ae27cb6f10e87aa6f5a078b1.zip | |
Fix SPARK-1034: Py4JException on PySpark Cartesian Result
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala b/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala index 0fb7e195b3..f430a33db1 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala @@ -49,8 +49,7 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])(implicit val kClassTag: ClassTag[K override def wrapRDD(rdd: RDD[(K, V)]): JavaPairRDD[K, V] = JavaPairRDD.fromRDD(rdd) - override val classTag: ClassTag[(K, V)] = - implicitly[ClassTag[AnyRef]].asInstanceOf[ClassTag[Tuple2[K, V]]] + override val classTag: ClassTag[(K, V)] = rdd.elementClassTag import JavaPairRDD._ |