diff options
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/KryoSerializer.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/KryoSerializer.scala b/core/src/main/scala/spark/KryoSerializer.scala index 8a3f565071..4b95e05bd3 100644 --- a/core/src/main/scala/spark/KryoSerializer.scala +++ b/core/src/main/scala/spark/KryoSerializer.scala @@ -256,7 +256,8 @@ class KryoSerializer extends Serializer with Logging { val regCls = System.getProperty("spark.kryo.registrator") if (regCls != null) { logInfo("Running user registrator: " + regCls) - val reg = Class.forName(regCls).newInstance().asInstanceOf[KryoRegistrator] + val classLoader = Thread.currentThread.getContextClassLoader + val reg = Class.forName(regCls, true, classLoader).newInstance().asInstanceOf[KryoRegistrator] reg.registerClasses(kryo) } kryo |