From 9419efea98e190766887a9ab5fbac57f45bf007c Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Mon, 27 Apr 2015 21:14:28 -0700 Subject: [PATCH] Bypass SerializationDebugger for now (SPARK-7180) --- .../org/apache/spark/util/ClosureCleanerSuite2.scala | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite2.scala b/core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite2.scala index e072b4128b804..934fe4f3a0a97 100644 --- a/core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite2.scala +++ b/core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite2.scala @@ -23,7 +23,7 @@ import scala.collection.mutable import org.scalatest.{BeforeAndAfterAll, FunSuite, PrivateMethodTester} -import org.apache.spark.{SparkContext, SparkException} +import org.apache.spark.{SparkConf, SparkContext, SparkException} import org.apache.spark.serializer.SerializerInstance /** @@ -38,7 +38,13 @@ class ClosureCleanerSuite2 extends FunSuite with BeforeAndAfterAll with PrivateM private var closureSerializer: SerializerInstance = null override def beforeAll(): Unit = { - sc = new SparkContext("local", "test") + val conf = new SparkConf() + .set("spark.master", "local") + .set("spark.app.name", "test") + // SerializationDebugger currently cannot serialize ClosureCleanerSuite2 because + // it has non-serializable fields but inherits a serializable class (SPARK-7180) + .set("spark.serializer.extraDebugInfo", "false") + sc = new SparkContext(conf) closureSerializer = sc.env.closureSerializer.newInstance() }