Skip to content
Snippets Groups Projects
Commit b3eeac55 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Fixed HttpBroadcast to work with this branch's Serializer.

parent f58da616
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment