From 2b84b50a85c4f2b3c3261b0e417dbe71fc2f9bce Mon Sep 17 00:00:00 2001 From: Denny Date: Tue, 17 Jul 2012 13:55:23 -0700 Subject: [PATCH] Use Context classloader for Serializer class --- core/src/main/scala/spark/SparkEnv.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/spark/SparkEnv.scala b/core/src/main/scala/spark/SparkEnv.scala index cd752f8b65..7e07811c90 100644 --- a/core/src/main/scala/spark/SparkEnv.scala +++ b/core/src/main/scala/spark/SparkEnv.scala @@ -26,7 +26,7 @@ object SparkEnv { val cache = Class.forName(cacheClass).newInstance().asInstanceOf[Cache] val serializerClass = System.getProperty("spark.serializer", "spark.JavaSerializer") - val serializer = Class.forName(serializerClass).newInstance().asInstanceOf[Serializer] + val serializer = Class.forName(serializerClass, true, Thread.currentThread.getContextClassLoader).newInstance().asInstanceOf[Serializer] val closureSerializerClass = System.getProperty("spark.closure.serializer", "spark.JavaSerializer")