We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 069d8a7 commit d5b409fCopy full SHA for d5b409f
core/src/test/scala/org/apache/spark/api/python/PythonBroadcastSuite.scala
@@ -48,8 +48,9 @@ class PythonBroadcastSuite extends FunSuite with Matchers {
48
}
49
val broadcast = new PythonBroadcast(broadcastDataFile.getAbsolutePath)
50
assertBroadcastIsValid(broadcast)
51
+ val conf = new SparkConf().set("spark.kryo.registrationRequired", "true")
52
val deserializedBroadcast =
- Utils.clone[PythonBroadcast](broadcast, new KryoSerializer(new SparkConf()).newInstance())
53
+ Utils.clone[PythonBroadcast](broadcast, new KryoSerializer(conf).newInstance())
54
assertBroadcastIsValid(deserializedBroadcast)
55
} finally {
56
Utils.deleteRecursively(tempDir)
0 commit comments