Permalink
Browse files

Revert "Fixed HttpBroadcast to work with this branch's Serializer."

This reverts commit b3eeac5.
  • Loading branch information...
1 parent 94d77f8 commit 800fcbfbca36a35290538ba24272ebc54690b152 @mateiz mateiz committed Jun 17, 2012
Showing with 2 additions and 2 deletions.
  1. +2 −2 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.serializeStream(out)
+ val serOut = ser.outputStream(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.deserializeStream(in)
+ val serIn = ser.inputStream(in)
val obj = serIn.readObject[T]()
serIn.close()
obj

0 comments on commit 800fcbf

Please sign in to comment.