diff options
author | Jacek Lewandowski <lewandowski.jacek@gmail.com> | 2015-01-20 12:38:01 -0800 |
---|---|---|
committer | Patrick Wendell <patrick@databricks.com> | 2015-01-20 12:38:01 -0800 |
commit | c93a57f0d6dc32b127aa68dbe4092ab0b22a9667 (patch) | |
tree | 1691f02b907ff298f32cfeb707c67d8118d3ca19 /core/src/main/scala/org/apache | |
parent | 814080278605148e7a75651283253d09a04e5a74 (diff) | |
download | spark-c93a57f0d6dc32b127aa68dbe4092ab0b22a9667.tar.gz spark-c93a57f0d6dc32b127aa68dbe4092ab0b22a9667.tar.bz2 spark-c93a57f0d6dc32b127aa68dbe4092ab0b22a9667.zip |
SPARK-4660: Use correct class loader in JavaSerializer (copy of PR #3840...
... by Piotr Kolaczkowski)
Author: Jacek Lewandowski <lewandowski.jacek@gmail.com>
Closes #4113 from jacek-lewandowski/SPARK-4660-master and squashes the following commits:
a5e84ca [Jacek Lewandowski] SPARK-4660: Use correct class loader in JavaSerializer (copy of PR #3840 by Piotr Kolaczkowski)
Diffstat (limited to 'core/src/main/scala/org/apache')
-rw-r--r-- | core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 662a7b9124..fa8a337ad6 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 = { |