+ bug fixes;

test added

Conflicts:

	core/src/test/scala/spark/KryoSerializerSuite.scala

1 files changed, 7 insertions, 1 deletions

diff --git a/core/src/test/scala/spark/KryoSerializerSuite.scala b/core/src/test/scala/spark/KryoSerializerSuite.scala
index 793b0b66c4..5ae7a427cc 100644
--- a/core/src/test/scala/spark/KryoSerializerSuite.scala
+++ b/core/src/test/scala/spark/KryoSerializerSuite.scala
@@ -24,7 +24,7 @@ import org.scalatest.FunSuite
 import com.esotericsoftware.kryo._
 
 import SparkContext._
-import spark.test.{ClassWithoutNoArgConstructor, MyRegistrator}
+import spark.test._
 
 class KryoSerializerSuite extends FunSuite with SharedSparkContext {
   test("basic types") {
@@ -134,6 +134,12 @@ class KryoSerializerSuite extends FunSuite with SharedSparkContext {
     assert(control == result.toSeq)
   }
 
+  test("kryo with parallelize") {
+    val control = 1 :: 2 :: Nil
+    val result = sc.parallelize(control.map(new ClassWithoutNoArgConstructor(_))).map(_.x).collect()
+    assert (control == result.toSeq)
+  }
+
   override def beforeAll() {
     System.setProperty("spark.serializer", "spark.KryoSerializer")
     System.setProperty("spark.kryo.registrator", classOf[MyRegistrator].getName)