diff --git a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
index c9f4aaa89a239fba60ad37b10c03c9177ee0f6e3..d0853eadf96f445ce7f85a9f18f2fdbf95874400 100644
--- a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
+++ b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
@@ -90,7 +90,7 @@ private object HttpBroadcast extends Logging {
       new FastBufferedOutputStream(new FileOutputStream(file), bufferSize)
     }
     val ser = SparkEnv.get.serializer.newInstance()
-    val serOut = ser.outputStream(out)
+    val serOut = ser.serializeStream(out)
     serOut.writeObject(value)
     serOut.close()
   }
@@ -103,7 +103,7 @@ private object HttpBroadcast extends Logging {
       new FastBufferedInputStream(new URL(url).openStream(), bufferSize)
     }
     val ser = SparkEnv.get.serializer.newInstance()
-    val serIn = ser.inputStream(in)
+    val serIn = ser.deserializeStream(in)
     val obj = serIn.readObject[T]()
     serIn.close()
     obj