From 8ed662862e7f822f2f70ddc70f5492f784cd861f Mon Sep 17 00:00:00 2001
From: Matei Zaharia <matei@eecs.berkeley.edu>
Date: Sat, 9 Jun 2012 16:16:48 -0700
Subject: [PATCH] Bug fix to HttpBroadcast
---
core/src/main/scala/spark/broadcast/HttpBroadcast.scala | 1 +
1 file changed, 1 insertion(+)
diff --git a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala
index 4714816591..ba8ba10141 100644
--- 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
}
}
--
GitLab