From b3eeac55b8f3c8c7b5ea18281d9d39dab63d5164 Mon Sep 17 00:00:00 2001
From: Matei Zaharia <matei@eecs.berkeley.edu>
Date: Fri, 15 Jun 2012 23:54:38 -0700
Subject: [PATCH] Fixed HttpBroadcast to work with this branch's Serializer.
---
core/src/main/scala/spark/broadcast/HttpBroadcast.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
index c9f4aaa89a..d0853eadf9 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
--
GitLab