From 86bc5ebdfb2c5f0d58ffeaf184f94f60923fe676 Mon Sep 17 00:00:00 2001 From: Piotr Kolaczkowski Date: Tue, 30 Dec 2014 12:01:47 +0100 Subject: [PATCH] SPARK-4660: Use correct default classloader in JavaSerializer. --- .../main/scala/org/apache/spark/serializer/JavaSerializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala b/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala index 662a7b91248a..fa8a337ad63a 100644 --- a/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala +++ b/core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala @@ -92,7 +92,7 @@ private[spark] class JavaSerializerInstance(counterReset: Int, defaultClassLoade } override def deserializeStream(s: InputStream): DeserializationStream = { - new JavaDeserializationStream(s, Utils.getContextOrSparkClassLoader) + new JavaDeserializationStream(s, defaultClassLoader) } def deserializeStream(s: InputStream, loader: ClassLoader): DeserializationStream = {