From af8e4618416923c499d5efc0b08538b7fd49e198 Mon Sep 17 00:00:00 2001
From: Ankur Dave <ankurdave@gmail.com>
Date: Wed, 16 Oct 2013 19:21:24 -0700
Subject: [PATCH] Set serialization properties in GraphSuite
---
graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git a/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala b/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
index 1b03b8094e..145be3c126 100644
--- a/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
+++ b/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
@@ -10,6 +10,9 @@ class GraphSuite extends FunSuite with LocalSparkContext {
// val sc = new SparkContext("local[4]", "test")
+ System.setProperty("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
+ System.setProperty("spark.kryo.registrator", "org.apache.spark.graph.GraphKryoRegistrator")
+
test("Graph Creation") {
withSpark(new SparkContext("local", "test")) { sc =>
val rawEdges = (0L to 100L).zip((1L to 99L) :+ 0L)
--
GitLab