Bug fix to HttpBroadcast

2012-06-09 16:16:48 -07:00 · 2012-06-09 16:16:48 -07:00 · 8ed662862e
parent e75b1b5cb4
commit 8ed662862e
1 changed files with 1 additions and 0 deletions
--- a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
+++ b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
@ -106,5 +106,6 @@ private object HttpBroadcast extends Logging {
    val serIn = ser.inputStream(in)
    val obj = serIn.readObject()
    serIn.close()
+    obj
  }
 }