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
23
23
24
24
import org .scalatest .{BeforeAndAfterAll , FunSuite , PrivateMethodTester }
25
25
26
- import org .apache .spark .{SparkContext , SparkException }
26
+ import org .apache .spark .{SparkConf , SparkContext , SparkException }
27
27
import org .apache .spark .serializer .SerializerInstance
28
28
29
29
/**
@@ -38,7 +38,13 @@ class ClosureCleanerSuite2 extends FunSuite with BeforeAndAfterAll with PrivateM
38
38
private var closureSerializer : SerializerInstance = null
39
39
40
40
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)
42
48
closureSerializer = sc.env.closureSerializer.newInstance()
43
49
}
44
50
You can’t perform that action at this time.
0 commit comments