We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 417f50e commit f90dc94Copy full SHA for f90dc94
core/src/main/scala/org/apache/spark/SerializableWritable.scala
@@ -19,7 +19,6 @@ package org.apache.spark
19
20
import java.io._
21
22
-import org.apache.hadoop.conf.Configuration
23
import org.apache.hadoop.io.ObjectWritable
24
import org.apache.hadoop.io.Writable
25
@@ -41,7 +40,6 @@ class SerializableWritable[T <: Writable](@transient var t: T) extends Serializa
41
40
private def readObject(in: ObjectInputStream): Unit = Utils.tryOrIOException {
42
in.defaultReadObject()
43
val ow = new ObjectWritable()
44
- ow.setConf(new Configuration())
45
ow.readFields(in)
46
t = ow.get().asInstanceOf[T]
47
}
0 commit comments