File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
core/src/test/scala/org/apache/spark/util Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ import scala.collection.mutable
2323
2424import org .scalatest .{BeforeAndAfterAll , FunSuite , PrivateMethodTester }
2525
26- import org .apache .spark .{SparkContext , SparkException }
26+ import org .apache .spark .{SparkConf , SparkContext , SparkException }
2727import org .apache .spark .serializer .SerializerInstance
2828
2929/**
@@ -38,7 +38,13 @@ class ClosureCleanerSuite2 extends FunSuite with BeforeAndAfterAll with PrivateM
3838 private var closureSerializer : SerializerInstance = null
3939
4040 override def beforeAll (): Unit = {
41- sc = new SparkContext (" local" , " test" )
41+ val conf = new SparkConf ()
42+ .set(" spark.master" , " local" )
43+ .set(" spark.app.name" , " test" )
44+ // SerializationDebugger currently cannot serialize ClosureCleanerSuite2 because
45+ // it has non-serializable fields but inherits a serializable class (SPARK-7180)
46+ .set(" spark.serializer.extraDebugInfo" , " false" )
47+ sc = new SparkContext (conf)
4248 closureSerializer = sc.env.closureSerializer.newInstance()
4349 }
4450
You can’t perform that action at this time.
0 commit comments