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 | |
| 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')
| -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 = { |